public class StreamMessageListenerAdapter extends MessagingMessageListenerAdapter implements StreamMessageListener
MessagingMessageListenerAdapter.MessagingMessageConverterAdapter
AbstractAdaptableMessageListener.ReplyExpressionRoot
logger
Constructor and Description |
---|
StreamMessageListenerAdapter(Object bean,
Method method,
boolean returnExceptions,
RabbitListenerErrorHandler errorHandler)
Construct an instance with the provided arguments.
|
Modifier and Type | Method and Description |
---|---|
void |
onStreamMessage(com.rabbitmq.stream.Message message,
com.rabbitmq.stream.MessageHandler.Context context)
Process a message.
|
buildMessage, getHandlerAdapter, getMessagingMessageConverter, invokeHandlerAndProcessResult, onMessage, setHandlerAdapter, setHeaderMapper, setMessageConverter, toMessagingMessage
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
containerAckMode, onMessage, onMessageBatch
onMessage, onMessageBatch
public StreamMessageListenerAdapter(Object bean, Method method, boolean returnExceptions, RabbitListenerErrorHandler errorHandler)
bean
- the bean.method
- the method.returnExceptions
- true to return exceptions.errorHandler
- the error handler.public void onStreamMessage(com.rabbitmq.stream.Message message, com.rabbitmq.stream.MessageHandler.Context context)
StreamMessageListener
onStreamMessage
in interface StreamMessageListener
message
- the message.context
- the stream context.