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
Fields Modifier and Type Field Description protected MessageConverterconverterprotected booleanmanualAcksprotected org.springframework.retry.RecoveryCallback<?>recovererprotected org.springframework.retry.RetryOperationsretryOps -
Constructor Summary
Constructors Modifier Constructor Description protectedListener() -
Method Summary
Modifier and Type Method Description protected ObjectconvertPayload(Message message)protected Message<Object>createMessageFromAmqp(Message message, com.rabbitmq.client.Channel channel)protected Message<Object>createMessageFromPayload(Object payload, com.rabbitmq.client.Channel channel, Map<String,Object> headers, long deliveryTag, List<Map<String,Object>> listHeaders)voidonMessage(Message message, com.rabbitmq.client.Channel channel)Methods 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, 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
-