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
Modifier and TypeFieldDescriptionprotected final MessageConverter
protected final boolean
protected final org.springframework.retry.RecoveryCallback<?>
protected final org.springframework.retry.RetryOperations
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected Object
convertPayload
(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) void
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener
onMessage, onMessageBatch
Methods 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:
onMessage
in interfaceChannelAwareMessageListener
-
createMessageFromAmqp
-
convertPayload
-
createMessageFromPayload
-