Package org.springframework.integration.amqp.inbound

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 MessageConverter	converter
protected boolean	manualAcks
protected org.springframework.retry.RecoveryCallback<?>	recoverer
protected org.springframework.retry.RetryOperations	retryOps

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Listener()

Method Summary

Modifier and Type	Method	Description
protected Object	convertPayload(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)
void	onMessage(Message message, com.rabbitmq.client.Channel channel)

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

protected final MessageConverter 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

public void onMessage(Message message, com.rabbitmq.client.Channel channel)

Specified by:

onMessage in interface ChannelAwareMessageListener

createMessageFromAmqp

protected Message<Object> createMessageFromAmqp(Message message, com.rabbitmq.client.Channel channel)

convertPayload

protected Object convertPayload(Message message)

createMessageFromPayload

protected Message<Object> createMessageFromPayload(Object payload, com.rabbitmq.client.Channel channel, Map<String,Object> headers, long deliveryTag, @Nullable List<Map<String,Object>> listHeaders)