public class BatchMessagingMessageListenerAdapter extends MessagingMessageListenerAdapter implements ChannelAwareBatchMessageListener
MessagingMessageListenerAdapter.MessagingMessageConverterAdapter
AbstractAdaptableMessageListener.ReplyExpressionRoot
logger
Constructor and Description |
---|
BatchMessagingMessageListenerAdapter(Object bean,
Method method,
boolean returnExceptions,
RabbitListenerErrorHandler errorHandler,
BatchingStrategy batchingStrategy) |
Modifier and Type | Method and Description |
---|---|
void |
onMessageBatch(List<Message> messages,
com.rabbitmq.client.Channel channel) |
protected Message<?> |
toMessagingMessage(Message amqpMessage) |
buildMessage, getMessagingMessageConverter, invokeHandlerAndProcessResult, onMessage, setHandlerAdapter, setHeaderMapper, setMessageConverter
containerAckMode, doHandleResult, doPublish, extractMessage, getEncoding, getMessageConverter, getReceivedExchange, getReplyToAddress, handleListenerException, handleResult, handleResult, postProcessChannel, postProcessResponse, sendResponse, setBeanResolver, setBeforeSendReplyPostProcessors, setDefaultRequeueRejected, setEncoding, setMandatoryPublish, setRecoveryCallback, setReplyPostProcessor, setResponseAddress, setResponseExchange, setResponseRoutingKey, setRetryTemplate
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onMessage
onMessage
containerAckMode, onMessageBatch
public BatchMessagingMessageListenerAdapter(Object bean, Method method, boolean returnExceptions, RabbitListenerErrorHandler errorHandler, @Nullable BatchingStrategy batchingStrategy)
public void onMessageBatch(List<Message> messages, com.rabbitmq.client.Channel channel)
onMessageBatch
in interface ChannelAwareBatchMessageListener
onMessageBatch
in interface ChannelAwareMessageListener
protected Message<?> toMessagingMessage(Message amqpMessage)
toMessagingMessage
in class MessagingMessageListenerAdapter