public class BatchMessagingMessageListenerAdapter extends MessagingMessageListenerAdapter implements ChannelAwareBatchMessageListener
MessagingMessageListenerAdapter.MessagingMessageConverterAdapterAbstractAdaptableMessageListener.ReplyExpressionRootlogger| 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, setMessageConvertercontainerAckMode, 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, setRetryTemplateclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitonMessageonMessagecontainerAckMode, onMessageBatchpublic 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 ChannelAwareBatchMessageListeneronMessageBatch in interface ChannelAwareMessageListenerprotected Message<?> toMessagingMessage(Message amqpMessage)
toMessagingMessage in class MessagingMessageListenerAdapter