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.MessagingMessageConverterAdapterNested 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 TypeMethodDescriptionvoidonStreamMessage(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, toMessagingMessageMethods 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, setRetryTemplateMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener
onMessage, onMessageBatchMethods 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:StreamMessageListenerProcess a message.- Specified by:
onStreamMessagein interfaceStreamMessageListener- Parameters:
message- the message.context- the stream context.
-