public class BatchMessagingMessageListenerAdapter extends MessagingMessageListenerAdapter implements ChannelAwareBatchMessageListener
MessagingMessageListenerAdapter.MessagingMessageConverterAdapterAbstractAdaptableMessageListener.ReplyExpressionRootlogger| Constructor and Description |
|---|
BatchMessagingMessageListenerAdapter(java.lang.Object bean,
java.lang.reflect.Method method,
boolean returnExceptions,
RabbitListenerErrorHandler errorHandler,
BatchingStrategy batchingStrategy) |
| Modifier and Type | Method and Description |
|---|---|
void |
onMessageBatch(java.util.List<org.springframework.amqp.core.Message> messages,
com.rabbitmq.client.Channel channel) |
protected org.springframework.messaging.Message<?> |
toMessagingMessage(org.springframework.amqp.core.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, waitonMessageonMessagepublic BatchMessagingMessageListenerAdapter(java.lang.Object bean,
java.lang.reflect.Method method,
boolean returnExceptions,
RabbitListenerErrorHandler errorHandler,
@Nullable
BatchingStrategy batchingStrategy)
public void onMessageBatch(java.util.List<org.springframework.amqp.core.Message> messages,
com.rabbitmq.client.Channel channel)
onMessageBatch in interface ChannelAwareBatchMessageListeneronMessageBatch in interface ChannelAwareMessageListenerprotected org.springframework.messaging.Message<?> toMessagingMessage(org.springframework.amqp.core.Message amqpMessage)
toMessagingMessage in class MessagingMessageListenerAdapter