Class AmqpInboundChannelAdapter.BatchListener

java.lang.Object

org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter.Listener

org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter.BatchListener

All Implemented Interfaces:

org.springframework.amqp.core.MessageListener, org.springframework.amqp.rabbit.listener.api.ChannelAwareBatchMessageListener, org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener

Enclosing class:

AmqpInboundChannelAdapter

protected class AmqpInboundChannelAdapter.BatchListener
extends AmqpInboundChannelAdapter.Listener
implements org.springframework.amqp.rabbit.listener.api.ChannelAwareBatchMessageListener

Since:

2.1

Field Summary

Fields inherited from class AmqpInboundChannelAdapter.Listener

converter, manualAcks, recoverer, retryOps

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BatchListener()

Method Summary

Modifier and Type	Method	Description
void	onMessageBatch(List<org.springframework.amqp.core.Message> messages, @Nullable com.rabbitmq.client.Channel channel)

Methods inherited from class AmqpInboundChannelAdapter.Listener

convertPayload, createMessageFromAmqp, createMessageFromPayload, onMessage

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.amqp.rabbit.listener.api.ChannelAwareBatchMessageListener

onMessage

Methods inherited from interface org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener

onMessage

Methods inherited from interface org.springframework.amqp.core.MessageListener

containerAckMode, isAsyncReplies, onMessageBatch

Constructor Details

BatchListener

protected BatchListener()

Method Details

onMessageBatch

public void onMessageBatch(List<org.springframework.amqp.core.Message> messages,
 @Nullable com.rabbitmq.client.Channel channel)

Specified by:

onMessageBatch in interface org.springframework.amqp.rabbit.listener.api.ChannelAwareBatchMessageListener

Specified by:

onMessageBatch in interface org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener