Class AmqpInboundChannelAdapter.Listener
java.lang.Object
org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter.Listener
- All Implemented Interfaces:
MessageListener,ChannelAwareMessageListener
- Direct Known Subclasses:
AmqpInboundChannelAdapter.BatchListener
- Enclosing class:
- AmqpInboundChannelAdapter
protected class AmqpInboundChannelAdapter.Listener
extends Object
implements ChannelAwareMessageListener
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final MessageConverterprotected final booleanprotected final org.springframework.retry.RecoveryCallback<?>protected final org.springframework.retry.RetryOperations -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected ObjectconvertPayload(Message message) createMessageFromAmqp(Message message, com.rabbitmq.client.Channel channel) createMessageFromPayload(Object payload, com.rabbitmq.client.Channel channel, Map<String, Object> headers, long deliveryTag, List<Map<String, Object>> listHeaders) voidMethods 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.ChannelAwareMessageListener
onMessage, onMessageBatchMethods inherited from interface org.springframework.amqp.core.MessageListener
containerAckMode, isAsyncReplies, onMessageBatch
-
Field Details
-
converter
-
manualAcks
protected final boolean manualAcks -
retryOps
protected final org.springframework.retry.RetryOperations retryOps -
recoverer
protected final org.springframework.retry.RecoveryCallback<?> recoverer
-
-
Constructor Details
-
Listener
protected Listener()
-
-
Method Details
-
onMessage
- Specified by:
onMessagein interfaceChannelAwareMessageListener
-
createMessageFromAmqp
-
convertPayload
-
createMessageFromPayload
-