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:

org.springframework.amqp.core.MessageListener, ChannelAwareBatchMessageListener, ChannelAwareMessageListener

public class BatchMessagingMessageListenerAdapter
extends MessagingMessageListenerAdapter
implements ChannelAwareBatchMessageListener

A listener adapter for batch listeners.

Since:

2.2

Nested Class Summary

Nested classes/interfaces inherited from class MessagingMessageListenerAdapter

MessagingMessageListenerAdapter.MessagingMessageConverterAdapter

Nested classes/interfaces inherited from class AbstractAdaptableMessageListener

AbstractAdaptableMessageListener.ReplyExpressionRoot

Field Summary

Fields inherited from class MessagingMessageListenerAdapter

errorHandler, messagingMessageConverter, returnExceptions

Fields inherited from class AbstractAdaptableMessageListener

logger

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class MessagingMessageListenerAdapter

asyncFailure, buildMessage, getHandlerAdapter, getMessagingMessageConverter, handleException, invokeHandler, invokeHandlerAndProcessResult, isAsyncReplies, onMessage, setHandlerAdapter, setHeaderMapper, setMessageConverter

Methods inherited from class AbstractAdaptableMessageListener

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

Methods inherited from class Object

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

Methods inherited from interface ChannelAwareBatchMessageListener

onMessage

Methods inherited from interface ChannelAwareMessageListener

onMessage

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

containerAckMode, isAsyncReplies, onMessageBatch

Constructor Details

BatchMessagingMessageListenerAdapter

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

Method Details

onMessageBatch

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

Specified by:

onMessageBatch in interface ChannelAwareBatchMessageListener

Specified by:

onMessageBatch in interface ChannelAwareMessageListener

toMessagingMessage

protected org.springframework.messaging.Message<?> toMessagingMessage(org.springframework.amqp.core.Message amqpMessage)

Overrides:

toMessagingMessage in class MessagingMessageListenerAdapter