Class 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
    • Nested Class Summary

      • Nested classes/interfaces inherited from class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter

        org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.MessagingMessageConverterAdapter
      • Nested classes/interfaces inherited from class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener

        org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener.ReplyExpressionRoot
    • Field Summary

      • Fields inherited from class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener

        logger
    • 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
      void onStreamMessage​(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
      • Methods inherited from interface org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener

        onMessage, onMessageBatch
      • Methods inherited from interface org.springframework.amqp.core.MessageListener

        containerAckMode, isAsyncReplies, onMessageBatch
    • 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: StreamMessageListener
        Process a message.
        Specified by:
        onStreamMessage in interface StreamMessageListener
        Parameters:
        message - the message.
        context - the stream context.