public class StreamMessageListenerAdapter extends org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter implements StreamMessageListener
| Constructor and 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.
|
| 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, waitpublic StreamMessageListenerAdapter(java.lang.Object bean,
java.lang.reflect.Method method,
boolean returnExceptions,
org.springframework.amqp.rabbit.listener.api.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.