Package org.springframework.amqp.rabbit.listener.adapter

Class BatchMessagingMessageListenerAdapter

java.lang.Object

org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener

org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter

org.springframework.amqp.rabbit.listener.adapter.BatchMessagingMessageListenerAdapter

All Implemented Interfaces:

MessageListener, ChannelAwareBatchMessageListener, ChannelAwareMessageListener

public class BatchMessagingMessageListenerAdapter
extends MessagingMessageListenerAdapter
implements ChannelAwareBatchMessageListener

A listener adapter for batch listeners.

Since:

2.2

Author:

Gary Russell

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter

MessagingMessageListenerAdapter.MessagingMessageConverterAdapter

Nested classes/interfaces inherited from class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener

AbstractAdaptableMessageListener.ReplyExpressionRoot

Field Summary

Fields inherited from class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener

logger

Constructor Summary

Constructors

Constructor	Description
BatchMessagingMessageListenerAdapter(Object bean, Method method, boolean returnExceptions, RabbitListenerErrorHandler errorHandler, BatchingStrategy batchingStrategy)

Method Summary

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

Methods inherited from class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter

buildMessage, getHandlerAdapter, getMessagingMessageConverter, invokeHandlerAndProcessResult, isAsyncReplies, onMessage, setHandlerAdapter, setHeaderMapper, setMessageConverter

Methods inherited from class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener

containerAckMode, convert, doHandleResult, doPublish, extractMessage, getEncoding, getMessageConverter, getReceivedExchange, getReplyContentType, getReplyToAddress, handleListenerException, handleResult, handleResult, isConverterWinsContentType, postProcessChannel, postProcessResponse, sendResponse, setBeanResolver, setBeforeSendReplyPostProcessors, setConverterWinsContentType, setDefaultRequeueRejected, setEncoding, setMandatoryPublish, setRecoveryCallback, setReplyContentType, setReplyPostProcessor, setResponseAddress, setResponseExchange, setResponseRoutingKey, setRetryTemplate

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, isAsyncReplies, onMessageBatch

Constructor Detail

BatchMessagingMessageListenerAdapter

public BatchMessagingMessageListenerAdapter(Object bean,
                                            Method method,
                                            boolean returnExceptions,
                                            RabbitListenerErrorHandler errorHandler,
                                            @Nullable
                                            BatchingStrategy batchingStrategy)

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

toMessagingMessage

protected Message<?> toMessagingMessage(Message amqpMessage)

Overrides:

toMessagingMessage in class MessagingMessageListenerAdapter