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
ConstructorsConstructorDescriptionStreamMessageListenerAdapter
(Object bean, Method method, boolean returnExceptions, RabbitListenerErrorHandler errorHandler) Construct an instance with the provided arguments. -
Method Summary
Modifier and TypeMethodDescriptionvoid
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, invokeHandler, invokeHandlerAndProcessResult, isAsyncReplies, onMessage, setHandlerAdapter, setHeaderMapper, setMessageConverter, toMessagingMessage
Methods inherited from class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
basicAck, containerAckMode, convert, doHandleResult, doPublish, extractMessage, getEncoding, getMessageConverter, getReceivedExchange, getReplyContentType, getReplyToAddress, handleListenerException, handleResult, handleResult, isConverterWinsContentType, isDefaultRequeueRejected, isManualAck, 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 interfaceStreamMessageListener
- Parameters:
message
- the message.context
- the stream context.
-