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.MessagingMessageConverterAdapterNested 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
ConstructorsConstructorDescriptionBatchMessagingMessageListenerAdapter(Object bean, Method method, boolean returnExceptions, RabbitListenerErrorHandler errorHandler, BatchingStrategy batchingStrategy) -
Method Summary
Modifier and TypeMethodDescriptionvoidonMessageBatch(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, setMessageConverterMethods 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, setRetryTemplateMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.springframework.amqp.rabbit.listener.api.ChannelAwareBatchMessageListener
onMessageMethods inherited from interface org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener
onMessageMethods inherited from interface org.springframework.amqp.core.MessageListener
containerAckMode, isAsyncReplies, onMessageBatch
-
Constructor Details
-
BatchMessagingMessageListenerAdapter
public BatchMessagingMessageListenerAdapter(Object bean, Method method, boolean returnExceptions, RabbitListenerErrorHandler errorHandler, @Nullable BatchingStrategy batchingStrategy)
-
-
Method Details
-
onMessageBatch
- Specified by:
onMessageBatchin interfaceChannelAwareBatchMessageListener- Specified by:
onMessageBatchin interfaceChannelAwareMessageListener
-
toMessagingMessage
- Overrides:
toMessagingMessagein classMessagingMessageListenerAdapter
-