Class AmqpMessageListenerContainerFactory

java.lang.Object

org.springframework.amqp.client.config.AmqpMessageListenerContainerFactory

Direct Known Subclasses:

MethodAmqpMessageListenerContainerFactory

public class AmqpMessageListenerContainerFactory
extends Object

The configuration factory to produce AmqpMessageListenerContainer instance based on the provided AmqpListenerEndpoint.

Since:

4.1

See Also:

• AmqpMessageListenerContainer

Constructor Summary

Constructors

Constructor	Description
AmqpMessageListenerContainerFactory(AmqpConnectionFactory connectionFactory)	Create an instance with the provided AmqpConnectionFactory.

Method Summary

Modifier and Type	Method	Description
protected void	configureEndpoint(AmqpListenerEndpoint endpoint)
AmqpMessageListenerContainer	createContainer(AmqpListenerEndpoint listenerEndpoint)	Create a AmqpMessageListenerContainer instance based on the provided AmqpListenerEndpoint.
void	setAdviceChain(org.aopalliance.aop.Advice... advices)	Set The default advice chain for container instances created by this factory.
void	setAutoAccept(boolean autoAccept)	The default auto accept flag for container instances created by this factory.
void	setAutoStartup(boolean autoStartup)	The default auto startup flag for container instances created by this factory.
void	setConcurrency(int concurrency)	The default concurrency for container instances created by this factory.
void	setErrorHandler(org.springframework.util.ErrorHandler errorHandler)	The ErrorHandler for container instances created by this factory.
void	setGracefulShutdownPeriod(Duration gracefulShutdownPeriod)	The default gracefulShutdownPeriod for container instances created by this factory.
void	setInitialCredits(int initialCredits)	The default initial credits value for container instances created by this factory.
void	setReceiveTimeout(Duration receiveTimeout)	The default receiveTimeout for container instances created by this factory.
void	setRecoveryBackOff(org.springframework.util.backoff.BackOff recoveryBackOff)	The default BackOff for a failed consumer recovery in container instances created by this factory.
void	setRecoveryInterval(Duration recoveryInterval)	The default recovery interval for container instances created by this factory.
void	setTaskExecutor(Executor taskExecutor)	The default Executor for container instances created by this factory.

Methods inherited from class Object

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

Constructor Details

AmqpMessageListenerContainerFactory

public AmqpMessageListenerContainerFactory(AmqpConnectionFactory connectionFactory)

Create an instance with the provided AmqpConnectionFactory.

Parameters:

connectionFactory - the connection factory to use.

Method Details

setConcurrency

public void setConcurrency(int concurrency)

The default concurrency for container instances created by this factory. Can be overridden by AmqpListenerEndpoint.getConcurrency(). Each AMQP address runs in its own consumer; set this property to create multiple consumers for each AMQP address.

Parameters:

concurrency - the consumers per AMQP address.

See Also:

• AmqpMessageListenerContainer.setConsumersPerQueue(int)

setAutoStartup

public void setAutoStartup(boolean autoStartup)

The default auto startup flag for container instances created by this factory. Can be overridden by AmqpListenerEndpoint.getAutoStartup().

Parameters:

autoStartup - the auto startup flag.

See Also:

• AmqpMessageListenerContainer.setAutoStartup(boolean)

setAutoAccept

public void setAutoAccept(boolean autoAccept)

The default auto accept flag for container instances created by this factory. Can be overridden by AmqpListenerEndpoint.getAutoAccept().

Parameters:

autoAccept - flag to use.

See Also:

• AmqpMessageListenerContainer.setAutoAccept(boolean)

setTaskExecutor

public void setTaskExecutor(Executor taskExecutor)

The default Executor for container instances created by this factory. Can be overridden by AmqpListenerEndpoint.getTaskExecutor().

Parameters:

taskExecutor - the task executor.

See Also:

• AmqpMessageListenerContainer.setTaskExecutor(Executor)

setInitialCredits

public void setInitialCredits(int initialCredits)

The default initial credits value for container instances created by this factory. Can be overridden by AmqpListenerEndpoint.getInitialCredits().

Parameters:

initialCredits - the initial credits.

See Also:

• AmqpMessageListenerContainer.setInitialCredits(int)

setReceiveTimeout

public void setReceiveTimeout(Duration receiveTimeout)

The default receiveTimeout for container instances created by this factory. Can be overridden by AmqpListenerEndpoint.getReceiveTimeout().

Parameters:

receiveTimeout - the timeout for receiving messages.

See Also:

• AmqpMessageListenerContainer.setReceiveTimeout(Duration)

setGracefulShutdownPeriod

public void setGracefulShutdownPeriod(Duration gracefulShutdownPeriod)

The default gracefulShutdownPeriod for container instances created by this factory. Can be overridden by AmqpListenerEndpoint.getGracefulShutdownPeriod().

Parameters:

gracefulShutdownPeriod - the timeout for shutdown.

See Also:

• AmqpMessageListenerContainer.setGracefulShutdownPeriod(Duration)

setRecoveryInterval

public void setRecoveryInterval(Duration recoveryInterval)

The default recovery interval for container instances created by this factory.

Parameters:

recoveryInterval - the interval between consumer recovery attempts.

Since:

4.1.1

See Also:

• AmqpMessageListenerContainer.setRecoveryInterval(Duration)

setRecoveryBackOff

public void setRecoveryBackOff(org.springframework.util.backoff.BackOff recoveryBackOff)

The default BackOff for a failed consumer recovery in container instances created by this factory.

Parameters:

recoveryBackOff - the BackOff to use for the consumer recovery.

Since:

4.1.1

See Also:

• AmqpMessageListenerContainer.setRecoveryBackOff(BackOff)

setAdviceChain

public void setAdviceChain(org.aopalliance.aop.Advice... advices)

Set The default advice chain for container instances created by this factory. Can be overridden by AmqpListenerEndpoint.getAdviceChain().

Parameters:

advices - the advice chain.

setErrorHandler

public void setErrorHandler(org.springframework.util.ErrorHandler errorHandler)

The ErrorHandler for container instances created by this factory.

Parameters:

errorHandler - the error handler.

createContainer

public AmqpMessageListenerContainer createContainer(AmqpListenerEndpoint listenerEndpoint)

Create a AmqpMessageListenerContainer instance based on the provided AmqpListenerEndpoint.

Parameters:

listenerEndpoint - the endpoint to configure a AmqpMessageListenerContainer instance.

Returns:

the container instance.

configureEndpoint

protected void configureEndpoint(AmqpListenerEndpoint endpoint)