public class StreamMessageListenerAdapter extends MessagingMessageListenerAdapter implements StreamMessageListener
MessagingMessageListenerAdapter.MessagingMessageConverterAdapterAbstractAdaptableMessageListener.ReplyExpressionRootlogger| 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, toMessagingMessagecontainerAckMode, 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, setRetryTemplateclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcontainerAckMode, onMessage, onMessageBatchonMessage, onMessageBatchpublic 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)
StreamMessageListeneronStreamMessage in interface StreamMessageListenermessage - the message.context - the stream context.