Package org.springframework.amqp.rabbit.listener

Class DirectReplyToMessageListenerContainer

java.lang.Object

org.springframework.amqp.rabbit.connection.RabbitAccessor

org.springframework.amqp.rabbit.listener.ObservableListenerContainer

org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer

org.springframework.amqp.rabbit.listener.DirectReplyToMessageListenerContainer

All Implemented Interfaces:

MessageListenerContainer, Aware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, ApplicationEventPublisherAware, Lifecycle, Phased, SmartLifecycle

public class DirectReplyToMessageListenerContainer
extends DirectMessageListenerContainer

Listener container for Direct ReplyTo only listens to the pseudo queue Address.AMQ_RABBITMQ_REPLY_TO. Consumers are added on-demand and terminated when idle for idleEventInterval (default 60 seconds).

Since:

2.0

Author:

Gary Russell

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DirectReplyToMessageListenerContainer.ChannelHolder	Holder for a channel; contains a consumer epoch used to prevent inappropriate release of the consumer after it has been allocated for reuse.

Nested classes/interfaces inherited from class org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer

DirectMessageListenerContainer.SimpleConsumer

Nested classes/interfaces inherited from class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

AbstractMessageListenerContainer.DefaultExclusiveConsumerLogger, AbstractMessageListenerContainer.JavaLangErrorHandler, AbstractMessageListenerContainer.SharedConnectionNotInitializedException, AbstractMessageListenerContainer.WrappedTransactionException

Field Summary

Fields inherited from class org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer

consumers

Fields inherited from class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

consumersLock, DEFAULT_DEBATCHING_ENABLED, DEFAULT_PREFETCH_COUNT, DEFAULT_RECOVERY_INTERVAL, DEFAULT_SHUTDOWN_TIMEOUT, lifecycleLock, stopNow

Fields inherited from class org.springframework.amqp.rabbit.connection.RabbitAccessor

logger

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
DirectReplyToMessageListenerContainer(ConnectionFactory connectionFactory)

Method Summary

Modifier and Type	Method	Description
final void	addQueueNames(String... queueNames)	Add queue(s) to this container's list of queues.
protected void	consumerRemoved(DirectMessageListenerContainer.SimpleConsumer consumer)	Called whenever a consumer is removed.
protected void	doStart()	Start this container, and notify all invoker tasks.
protected int	findIdleConsumer()	When adjusting down, return a consumer that can be canceled.
DirectReplyToMessageListenerContainer.ChannelHolder	getChannelHolder()	Get the channel holder associated with a direct reply-to consumer; contains a consumer epoch to prevent inappropriate releases.
protected void	processMonitorTask()	Subclasses can override this to take additional actions when the monitor task runs.
void	releaseConsumerFor(DirectReplyToMessageListenerContainer.ChannelHolder channelHolder, boolean cancelConsumer, String message)	Release the consumer associated with the channel for reuse.
final boolean	removeQueueNames(String... queueNames)	Remove queue(s) from this container's list of queues.
final void	setConsumersPerQueue(int consumersPerQueue)	Each queue runs in its own consumer; set this property to create multiple consumers for each queue.
void	setMessageListener(MessageListener messageListener)	Set the MessageListener.
final void	setMonitorInterval(long monitorInterval)	Set how often to run a task to check for failed consumers and idle containers.
final void	setQueueNames(String... queueName)	Set the name of the queue(s) to receive messages from.

Methods inherited from class org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer

actualStart, addQueues, checkConnect, doInitialize, doRedeclareElementsIfNecessary, doStop, removeQueues, setAckTimeout, setExclusive, setMessagesPerAck, setMissingQueuesFatal, setTaskScheduler, shutdownAndWaitOrCallback

Methods inherited from class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

actualInvokeListener, addAfterReceivePostProcessors, afterPropertiesSet, causeChainHasImmediateAcknowledgeAmqpException, checkMessageListener, checkMismatchedQueues, configureAdminIfNeeded, debatch, destroy, doInvokeListener, doInvokeListener, doSetPossibleAuthenticationFailureFatal, doShutdown, executeListener, executeListenerAndHandleException, getAcknowledgeMode, getAdviceChain, getAfterReceivePostProcessors, getAmqpAdmin, getApplicationEventPublisher, getBatchingStrategy, getConnectionFactory, getConsumeDelay, getConsumerArguments, getConsumerTagStrategy, getExclusiveConsumerExceptionLogger, getFailedDeclarationRetryInterval, getIdleEventInterval, getJavaLangErrorHandler, getLastReceive, getMessageAckListener, getMessageListener, getMessagePropertiesConverter, getPhase, getPrefetchCount, getQueueNames, getQueueNamesAsSet, getQueueNamesToQueues, getRecoveryBackOff, getRoutingConnectionFactory, getRoutingLookupKey, getShutdownTimeout, getTaskExecutor, getTransactionAttribute, getTransactionManager, handleListenerException, initialize, initializeProxy, invokeErrorHandler, invokeListener, isActive, isAlwaysRequeueWithTxManagerRollback, isAsyncReplies, isAutoDeclare, isAutoStartup, isChannelLocallyTransacted, isDeBatchingEnabled, isDefaultRequeueRejected, isExclusive, isExposeListenerChannel, isForceCloseChannel, isForceStop, isGlobalQos, isMismatchedQueuesFatal, isMissingQueuesFatal, isMissingQueuesFatalSet, isNoLocal, isPossibleAuthenticationFailureFatal, isPossibleAuthenticationFailureFatalSet, isRunning, isStatefulRetryFatalWithNullMessageId, lazyLoad, prepareHolderForRollback, publishConsumerFailedEvent, publishIdleContainerEvent, publishMissingQueueEvent, redeclareElementsIfNecessary, removeAfterReceivePostProcessor, setAcknowledgeMode, setAdviceChain, setAfterReceivePostProcessors, setAlwaysRequeueWithTxManagerRollback, setAmqpAdmin, setApplicationEventPublisher, setAutoDeclare, setAutoStartup, setBatchingStrategy, setConsumeDelay, setConsumerArguments, setConsumerTagStrategy, setDeBatchingEnabled, setDefaultRequeueRejected, setErrorHandler, setErrorHandlerLoggerName, setExclusiveConsumerExceptionLogger, setExposeListenerChannel, setFailedDeclarationRetryInterval, setForceCloseChannel, setForceStop, setGlobalQos, setIdleEventInterval, setjavaLangErrorHandler, setLookupKeyQualifier, setMessageAckListener, setMessagePropertiesConverter, setMismatchedQueuesFatal, setNoLocal, setNotRunning, setObservationConvention, setPhase, setPossibleAuthenticationFailureFatal, setPrefetchCount, setQueues, setRecoveryBackOff, setRecoveryInterval, setShutdownTimeout, setStatefulRetryFatalWithNullMessageId, setTaskExecutor, setTransactionAttribute, setTransactionManager, setupMessageListener, shutdown, shutdown, start, stop, stop, updateLastReceive, validateConfiguration, wrapToListenerExecutionFailedExceptionIfNeeded

Methods inherited from class org.springframework.amqp.rabbit.listener.ObservableListenerContainer

checkMicrometer, checkObservation, getApplicationContext, getBeanName, getListenerId, getMicrometerHolder, setApplicationContext, setBeanName, setListenerId, setMicrometerEnabled, setMicrometerTags, setObservationEnabled

Methods inherited from class org.springframework.amqp.rabbit.connection.RabbitAccessor

convertRabbitAccessException, createConnection, getChannel, getConnection, getObservationRegistry, getTransactionalResourceHolder, isChannelTransacted, obtainObservationRegistry, setChannelTransacted, setConnectionFactory

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.MessageListenerContainer

isConsumerBatchEnabled

Constructor Details

DirectReplyToMessageListenerContainer

public DirectReplyToMessageListenerContainer(ConnectionFactory connectionFactory)

Method Details

setConsumersPerQueue

public final void setConsumersPerQueue(int consumersPerQueue)

Description copied from class: DirectMessageListenerContainer

Each queue runs in its own consumer; set this property to create multiple consumers for each queue. If the container is already running, the number of consumers per queue will be adjusted up or down as necessary.

Overrides:

setConsumersPerQueue in class DirectMessageListenerContainer

Parameters:

consumersPerQueue - the consumers per queue.

setMonitorInterval

public final void setMonitorInterval(long monitorInterval)

Description copied from class: DirectMessageListenerContainer

Set how often to run a task to check for failed consumers and idle containers.

Overrides:

setMonitorInterval in class DirectMessageListenerContainer

Parameters:

monitorInterval - the interval; default 10000 but it will be adjusted down to the smallest of this, idleEventInterval / 2 (if configured) or failedDeclarationRetryInterval.

setQueueNames

public final void setQueueNames(String... queueName)

Description copied from class: AbstractMessageListenerContainer

Set the name of the queue(s) to receive messages from.

Specified by:

setQueueNames in interface MessageListenerContainer

Overrides:

setQueueNames in class DirectMessageListenerContainer

Parameters:

queueName - the desired queueName(s) (can not be null)

addQueueNames

public final void addQueueNames(String... queueNames)

Description copied from class: AbstractMessageListenerContainer

Add queue(s) to this container's list of queues.

Overrides:

addQueueNames in class DirectMessageListenerContainer

Parameters:

queueNames - The queue(s) to add.

removeQueueNames

public final boolean removeQueueNames(String... queueNames)

Description copied from class: AbstractMessageListenerContainer

Remove queue(s) from this container's list of queues.

Overrides:

removeQueueNames in class DirectMessageListenerContainer

Parameters:

queueNames - The queue(s) to remove.

Returns:

the boolean result of removal on the target queueNames List.

setMessageListener

public void setMessageListener(MessageListener messageListener)

Description copied from class: AbstractMessageListenerContainer

Set the MessageListener.

Overrides:

setMessageListener in class AbstractMessageListenerContainer

Parameters:

messageListener - the listener.

doStart

protected void doStart()

Description copied from class: AbstractMessageListenerContainer

Start this container, and notify all invoker tasks.

Overrides:

doStart in class DirectMessageListenerContainer

processMonitorTask

protected void processMonitorTask()

Description copied from class: DirectMessageListenerContainer

Subclasses can override this to take additional actions when the monitor task runs.

Overrides:

processMonitorTask in class DirectMessageListenerContainer

findIdleConsumer

protected int findIdleConsumer()

Description copied from class: DirectMessageListenerContainer

When adjusting down, return a consumer that can be canceled. Called while locked on AbstractMessageListenerContainer.consumersLock.

Overrides:

findIdleConsumer in class DirectMessageListenerContainer

Returns:

the consumer index or -1 if non-idle.

consumerRemoved

protected void consumerRemoved(DirectMessageListenerContainer.SimpleConsumer consumer)

Description copied from class: DirectMessageListenerContainer

Called whenever a consumer is removed.

Overrides:

consumerRemoved in class DirectMessageListenerContainer

Parameters:

consumer - the consumer.

getChannelHolder

public DirectReplyToMessageListenerContainer.ChannelHolder getChannelHolder()

Get the channel holder associated with a direct reply-to consumer; contains a consumer epoch to prevent inappropriate releases.

Returns:

the channel holder.

releaseConsumerFor

public void releaseConsumerFor(DirectReplyToMessageListenerContainer.ChannelHolder channelHolder,
 boolean cancelConsumer,
 @Nullable
 String message)

Release the consumer associated with the channel for reuse. Set cancelConsumer to true if the client is not prepared to handle/discard a late arriving reply.

Parameters:

channelHolder - the channel holder.

cancelConsumer - true to cancel the consumer.

message - a message to be included in the cancel event if cancelConsumer is true.