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(java.lang.Object bean, java.lang.reflect.Method method, boolean returnExceptions, RabbitListenerErrorHandler errorHandler)
Construct an instance with the provided arguments.
-
Method Summary
All Methods Instance Methods Concrete Methods 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
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 Detail
-
StreamMessageListenerAdapter
public StreamMessageListenerAdapter(java.lang.Object bean, java.lang.reflect.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 Detail
-
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 interfaceStreamMessageListener
- Parameters:
message
- the message.context
- the stream context.
-
-