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