org.springframework.integration.amqp.inbound

Class AmqpInboundGateway

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.endpoint.AbstractEndpoint

org.springframework.integration.gateway.MessagingGatewaySupport

org.springframework.integration.amqp.inbound.AmqpInboundGateway

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, ExpressionCapable, IntegrationPattern, NamedComponent, IntegrationInboundManagement, IntegrationManagement, ManageableLifecycle, ManageableSmartLifecycle, TrackableComponent

public class AmqpInboundGateway
extends MessagingGatewaySupport

Adapter that receives Messages from an AMQP Queue, converts them into Spring Integration Messages, and sends the results to a Message Channel. If a reply Message is received, it will be converted and sent back to the AMQP 'replyTo'.

Since:

2.1

Author:

Mark Fisher, Artem Bilan, Gary Russell

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AmqpInboundGateway.Listener

Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

Fields inherited from class org.springframework.integration.gateway.MessagingGatewaySupport

messagingTemplate

Fields inherited from class org.springframework.integration.endpoint.AbstractEndpoint

lifecycleCondition, lifecycleLock

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor and Description
AmqpInboundGateway(AbstractMessageListenerContainer listenerContainer)
AmqpInboundGateway(AbstractMessageListenerContainer listenerContainer, AmqpTemplate amqpTemplate) Construct AmqpInboundGateway based on the provided AbstractMessageListenerContainer to receive request messages and AmqpTemplate to send replies.

Method Summary

Modifier and Type	Method and Description
protected void	doStart() Subclasses must implement this method with the start behavior.
protected void	doStop() Subclasses must implement this method with the stop behavior.
String	getComponentType() Subclasses may implement this method to provide component type information.
protected AttributeAccessor	getErrorMessageAttributes(Message<?> message) Populate an AttributeAccessor to be used when building an error message with the errorMessageStrategy.
protected void	onInit() Subclasses may implement this for initialization logic.
void	setBatchingStrategy(BatchingStrategy batchingStrategy) Set a batching strategy to use when de-batching messages.
void	setBindSourceMessage(boolean bindSourceMessage) Set to true to bind the source message in the header named IntegrationMessageHeaderAccessor.SOURCE_DATA.
void	setDefaultReplyTo(String defaultReplyTo) The defaultReplyTo address with the form (exchange)/(routingKey)
void	setHeaderMapper(AmqpHeaderMapper headerMapper)
void	setMessageConverter(MessageConverter messageConverter) Specify the MessageConverter to convert request and reply to/from Message.
void	setRecoveryCallback(org.springframework.retry.RecoveryCallback<? extends Object> recoveryCallback) Set a RecoveryCallback when using retry within the gateway.
void	setReplyHeadersMappedLast(boolean replyHeadersMappedLast) When mapping headers for the outbound (reply) message, determine whether the headers are mapped before the message is converted, or afterwards.
void	setRetryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate) Set a RetryTemplate to use for retrying a message delivery within the gateway.

Methods inherited from class org.springframework.integration.gateway.MessagingGatewaySupport

buildErrorMessage, buildSendTimer, destroy, getErrorChannel, getIntegrationPatternType, getManagedName, getManagedType, getOverrides, getReplyChannel, getRequestChannel, isLoggingEnabled, receive, receive, receiveMessage, receiveMessage, registerMetricsCaptor, registerReplyMessageCorrelatorIfNecessary, send, sendAndReceive, sendAndReceiveMessage, sendAndReceiveMessageReactive, sendTimer, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setErrorOnTimeout, setLoggingEnabled, setManagedName, setManagedType, setReplyChannel, setReplyChannelName, setReplyMapper, setReplyTimeout, setRequestChannel, setRequestChannelName, setRequestMapper, setRequestTimeout, setShouldTrack

Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint

doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.springframework.integration.support.management.IntegrationManagement

getThisAs

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

getBeanName, getComponentName

Constructor Detail

AmqpInboundGateway

public AmqpInboundGateway(AbstractMessageListenerContainer listenerContainer)

AmqpInboundGateway

public AmqpInboundGateway(AbstractMessageListenerContainer listenerContainer,
                          AmqpTemplate amqpTemplate)

Construct AmqpInboundGateway based on the provided AbstractMessageListenerContainer to receive request messages and AmqpTemplate to send replies.

Parameters:

listenerContainer - the AbstractMessageListenerContainer to receive AMQP messages.

amqpTemplate - the AmqpTemplate to send reply messages.

Since:

4.2

Method Detail

setMessageConverter

public void setMessageConverter(MessageConverter messageConverter)

Specify the MessageConverter to convert request and reply to/from Message. If the amqpTemplate is explicitly set, this MessageConverter isn't populated there. You must configure that external amqpTemplate.

Parameters:

messageConverter - the MessageConverter to use.

setHeaderMapper

public void setHeaderMapper(AmqpHeaderMapper headerMapper)

setDefaultReplyTo

public void setDefaultReplyTo(String defaultReplyTo)

The defaultReplyTo address with the form

 (exchange)/(routingKey)
 

or

 (queueName)
 

if the request message doesn't have a replyTo property. The second form uses the default exchange ("") and the queue name as the routing key.

Parameters:

defaultReplyTo - the default replyTo address to use.

Since:

4.2

See Also:

Address

setRetryTemplate

public void setRetryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)

Set a RetryTemplate to use for retrying a message delivery within the gateway. Unlike adding retry at the container level, this can be used with an ErrorMessageSendingRecoverer RecoveryCallback to publish to the error channel after retries are exhausted. You generally should not configure an error channel when using retry here, use a RecoveryCallback instead.

Parameters:

retryTemplate - the template.

Since:

4.3.10.

See Also:

setRecoveryCallback(RecoveryCallback)

setRecoveryCallback

public void setRecoveryCallback(org.springframework.retry.RecoveryCallback<? extends Object> recoveryCallback)

Set a RecoveryCallback when using retry within the gateway.

Parameters:

recoveryCallback - the callback.

Since:

4.3.10

See Also:

setRetryTemplate(RetryTemplate)

setBatchingStrategy

public void setBatchingStrategy(BatchingStrategy batchingStrategy)

Set a batching strategy to use when de-batching messages. Default is SimpleBatchingStrategy.

Parameters:

batchingStrategy - the strategy.

Since:

5.2

setBindSourceMessage

public void setBindSourceMessage(boolean bindSourceMessage)

Set to true to bind the source message in the header named IntegrationMessageHeaderAccessor.SOURCE_DATA.

Parameters:

bindSourceMessage - true to bind.

Since:

5.1.6

setReplyHeadersMappedLast

public void setReplyHeadersMappedLast(boolean replyHeadersMappedLast)

When mapping headers for the outbound (reply) message, determine whether the headers are mapped before the message is converted, or afterwards. This only affects headers that might be added by the message converter. When false, the converter's headers win; when true, any headers added by the converter will be overridden (if the source message has a header that maps to those headers). You might wish to set this to true, for example, when using a SimpleMessageConverter with a String payload that contains json; the converter will set the content type to text/plain which can be overridden to application/json by setting the AmqpHeaders.CONTENT_TYPE message header. Default: false.

Parameters:

replyHeadersMappedLast - true if reply headers are mapped after conversion.

Since:

5.1.9

getComponentType

public String getComponentType()

Description copied from class: IntegrationObjectSupport

Subclasses may implement this method to provide component type information.

Specified by:

getComponentType in interface NamedComponent

Overrides:

getComponentType in class MessagingGatewaySupport

onInit

protected void onInit()

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class MessagingGatewaySupport

doStart

protected void doStart()

Description copied from class: AbstractEndpoint

Subclasses must implement this method with the start behavior. This method will be invoked while holding the AbstractEndpoint.lifecycleLock.

Overrides:

doStart in class MessagingGatewaySupport

doStop

protected void doStop()

Description copied from class: AbstractEndpoint

Subclasses must implement this method with the stop behavior. This method will be invoked while holding the AbstractEndpoint.lifecycleLock.

Overrides:

doStop in class MessagingGatewaySupport

getErrorMessageAttributes

protected AttributeAccessor getErrorMessageAttributes(Message<?> message)

Description copied from class: MessagingGatewaySupport

Populate an AttributeAccessor to be used when building an error message with the errorMessageStrategy.

Overrides:

getErrorMessageAttributes in class MessagingGatewaySupport

Parameters:

message - the message.

Returns:

the attributes.