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:
org.springframework.amqp.core.MessageListener,org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener,StreamMessageListener
public class StreamMessageListenerAdapter extends org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter implements StreamMessageListener
A listener adapter that receives native stream messages.- Since:
- 2.4
-
-
Constructor Summary
Constructors Constructor Description StreamMessageListenerAdapter(java.lang.Object bean, java.lang.reflect.Method method, boolean returnExceptions, org.springframework.amqp.rabbit.listener.api.RabbitListenerErrorHandler errorHandler)Construct an instance with the provided arguments.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidonStreamMessage(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
-
-
-
-
Constructor Detail
-
StreamMessageListenerAdapter
public StreamMessageListenerAdapter(java.lang.Object bean, java.lang.reflect.Method method, boolean returnExceptions, org.springframework.amqp.rabbit.listener.api.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:StreamMessageListenerProcess a message.- Specified by:
onStreamMessagein interfaceStreamMessageListener- Parameters:
message- the message.context- the stream context.
-
-