Interface ChannelAwareMessageListener

    • Method Detail

      • onMessage

        void onMessage​(Message message,
                       @Nullable
                       com.rabbitmq.client.Channel channel)
                throws Exception
        Callback for processing a received Rabbit message.

        Implementors are supposed to process the given Message, typically sending reply messages through the given Session.

        Parameters:
        message - the received AMQP message (never null)
        channel - the underlying Rabbit Channel (never null unless called by the stream listener container).
        Throws:
        Exception - Any.
      • onMessageBatch

        default void onMessageBatch​(List<Message> messages,
                                    com.rabbitmq.client.Channel channel)