org.springframework.integration.amqp.inbound

Class AmqpInboundChannelAdapter.BatchListener

java.lang.Object

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

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

All Implemented Interfaces:

MessageListener, ChannelAwareBatchMessageListener, ChannelAwareMessageListener

Enclosing class:

AmqpInboundChannelAdapter

protected class AmqpInboundChannelAdapter.BatchListener
extends AmqpInboundChannelAdapter.Listener
implements ChannelAwareBatchMessageListener

Field Summary

Fields inherited from class org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter.Listener

converter, manualAcks, recoverer, retryOps

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BatchListener()

Method Summary

Modifier and Type	Method and Description
void	onMessageBatch(List<Message> messages, com.rabbitmq.client.Channel channel)

Methods inherited from class org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter.Listener

convertPayload, createMessageFromAmqp, createMessageFromPayload, onMessage

Methods inherited from class java.lang.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, onMessageBatch

Constructor Detail

BatchListener

protected BatchListener()

Method Detail

onMessageBatch

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

Specified by:

onMessageBatch in interface ChannelAwareBatchMessageListener

Specified by:

onMessageBatch in interface ChannelAwareMessageListener