Package org.springframework.rabbit.stream.listener.adapter

Class StreamMessageListenerAdapter

java.lang.Object

org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener

org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter

org.springframework.rabbit.stream.listener.adapter.StreamMessageListenerAdapter

All Implemented Interfaces:

MessageListener, ChannelAwareMessageListener, StreamMessageListener

public class StreamMessageListenerAdapter
extends MessagingMessageListenerAdapter
implements StreamMessageListener

A listener adapter that receives native stream messages.

Since:

2.4

Author:

Gary Russell

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter

MessagingMessageListenerAdapter.MessagingMessageConverterAdapter

Nested classes/interfaces inherited from class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener

AbstractAdaptableMessageListener.ReplyExpressionRoot

Field Summary

Fields inherited from class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener

logger

Constructor Summary

Constructors

Constructor	Description
StreamMessageListenerAdapter(Object bean, Method method, boolean returnExceptions, RabbitListenerErrorHandler errorHandler)	Construct an instance with the provided arguments.

Method Summary

Modifier and Type	Method	Description
void	onStreamMessage(com.rabbitmq.stream.Message message, com.rabbitmq.stream.MessageHandler.Context context)	Process a message.

Methods inherited from class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter

asyncFailure, buildMessage, getHandlerAdapter, getMessagingMessageConverter, invokeHandlerAndProcessResult, isAsyncReplies, onMessage, setHandlerAdapter, setHeaderMapper, setMessageConverter, toMessagingMessage

Methods inherited from class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener

containerAckMode, convert, doHandleResult, doPublish, extractMessage, getEncoding, getMessageConverter, getReceivedExchange, getReplyContentType, getReplyToAddress, handleListenerException, handleResult, handleResult, isConverterWinsContentType, postProcessChannel, postProcessResponse, sendResponse, setBeanResolver, setBeforeSendReplyPostProcessors, setConverterWinsContentType, setDefaultRequeueRejected, setEncoding, setMandatoryPublish, setRecoveryCallback, setReplyContentType, setReplyPostProcessor, setResponseAddress, setResponseExchange, setResponseRoutingKey, setRetryTemplate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener

onMessage, onMessageBatch

Methods inherited from interface org.springframework.amqp.core.MessageListener

containerAckMode, isAsyncReplies, onMessageBatch

Constructor Details

StreamMessageListenerAdapter

public StreamMessageListenerAdapter(Object bean,
 Method method,
 boolean returnExceptions,
 RabbitListenerErrorHandler errorHandler)

Construct an instance with the provided arguments.

Parameters:

bean - the bean.

method - the method.

returnExceptions - true to return exceptions.

errorHandler - the error handler.

Method Details

onStreamMessage

public void onStreamMessage(com.rabbitmq.stream.Message message,
 com.rabbitmq.stream.MessageHandler.Context context)

Description copied from interface: StreamMessageListener

Process a message.

Specified by:

onStreamMessage in interface StreamMessageListener

Parameters:

message - the message.

context - the stream context.