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
  • 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(Object bean, Method method, boolean returnExceptions, org.springframework.amqp.rabbit.listener.api.RabbitListenerErrorHandler errorHandler)
    Construct an instance with the provided arguments.
  • Method Summary

    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 Details

    • StreamMessageListenerAdapter

      public StreamMessageListenerAdapter(Object bean, 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 Details

    • 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.