@FunctionalInterface public interface ChannelAwareMessageListener extends MessageListener
Modifier and Type | Method and Description |
---|---|
default void |
onMessage(Message message)
Delivers a single message.
|
void |
onMessage(Message message,
com.rabbitmq.client.Channel channel)
Callback for processing a received Rabbit message.
|
default void |
onMessageBatch(List<Message> messages,
com.rabbitmq.client.Channel channel) |
containerAckMode, onMessageBatch
void onMessage(Message message, @Nullable com.rabbitmq.client.Channel channel) throws Exception
Implementors are supposed to process the given Message, typically sending reply messages through the given Session.
message
- the received AMQP message (never null
)channel
- the underlying Rabbit Channel (never null
unless called by the stream listener container).Exception
- Any.default void onMessage(Message message)
MessageListener
onMessage
in interface MessageListener
message
- the message.