@FunctionalInterface
public interface ChannelAwareMessageListener
extends org.springframework.amqp.core.MessageListener
| Modifier and Type | Method and Description |
|---|---|
default void |
onMessage(org.springframework.amqp.core.Message message) |
void |
onMessage(org.springframework.amqp.core.Message message,
com.rabbitmq.client.Channel channel)
Callback for processing a received Rabbit message.
|
default void |
onMessageBatch(java.util.List<org.springframework.amqp.core.Message> messages,
com.rabbitmq.client.Channel channel) |
void onMessage(org.springframework.amqp.core.Message message,
com.rabbitmq.client.Channel channel)
throws java.lang.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)java.lang.Exception - Any.default void onMessage(org.springframework.amqp.core.Message message)
onMessage in interface org.springframework.amqp.core.MessageListenerdefault void onMessageBatch(java.util.List<org.springframework.amqp.core.Message> messages,
com.rabbitmq.client.Channel channel)