Class AbstractRabbitListenerContainerFactoryConfigurer<T extends org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory<?>>

java.lang.Object

org.springframework.boot.amqp.autoconfigure.AbstractRabbitListenerContainerFactoryConfigurer<T>

Type Parameters:

T - the container factory type.

Direct Known Subclasses:

DirectRabbitListenerContainerFactoryConfigurer, SimpleRabbitListenerContainerFactoryConfigurer

public abstract class AbstractRabbitListenerContainerFactoryConfigurer<T extends org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory<?>>
extends Object

Base class for configurers of sub-classes of AbstractRabbitListenerContainerFactory.

Since:

4.0.0

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractRabbitListenerContainerFactoryConfigurer(RabbitProperties rabbitProperties)	Creates a new configurer that will use the given rabbitProperties.

Method Summary

Modifier and Type	Method	Description
abstract void	configure(T factory, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)	Configure the specified rabbit listener container factory.
protected void	configure(T factory, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, RabbitProperties.AmqpContainer configuration)
protected final RabbitProperties	getRabbitProperties()
protected void	setMessageConverter(@Nullable org.springframework.amqp.support.converter.MessageConverter messageConverter)	Set the MessageConverter to use or null if the out-of-the-box converter should be used.
protected void	setMessageRecoverer(@Nullable org.springframework.amqp.rabbit.retry.MessageRecoverer messageRecoverer)	Set the MessageRecoverer to use or null to rely on the default.
protected void	setRetrySettingsCustomizers(@Nullable List<RabbitListenerRetrySettingsCustomizer> retrySettingsCustomizers)	Set the RabbitListenerRetrySettingsCustomizer instances to use.
void	setTaskExecutor(@Nullable Executor taskExecutor)	Set the task executor to use.

Methods inherited from class Object

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

Constructor Details

AbstractRabbitListenerContainerFactoryConfigurer

protected AbstractRabbitListenerContainerFactoryConfigurer(RabbitProperties rabbitProperties)

Creates a new configurer that will use the given rabbitProperties.

Parameters:

rabbitProperties - properties to use

Method Details

setMessageConverter

protected void setMessageConverter(@Nullable org.springframework.amqp.support.converter.MessageConverter messageConverter)

Set the MessageConverter to use or null if the out-of-the-box converter should be used.

Parameters:

messageConverter - the MessageConverter

setMessageRecoverer

protected void setMessageRecoverer(@Nullable org.springframework.amqp.rabbit.retry.MessageRecoverer messageRecoverer)

Set the MessageRecoverer to use or null to rely on the default.

Parameters:

messageRecoverer - the MessageRecoverer

setRetrySettingsCustomizers

protected void setRetrySettingsCustomizers(@Nullable List<RabbitListenerRetrySettingsCustomizer> retrySettingsCustomizers)

Set the RabbitListenerRetrySettingsCustomizer instances to use.

Parameters:

retrySettingsCustomizers - the retry settings customizers

setTaskExecutor

public void setTaskExecutor(@Nullable Executor taskExecutor)

Set the task executor to use.

Parameters:

taskExecutor - the task executor

getRabbitProperties

protected final RabbitProperties getRabbitProperties()

configure

public abstract void configure(T factory,
 org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)

Configure the specified rabbit listener container factory. The factory can be further tuned and default settings can be overridden.

Parameters:

factory - the AbstractRabbitListenerContainerFactory instance to configure

connectionFactory - the ConnectionFactory to use

configure

protected void configure(T factory,
 org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
 RabbitProperties.AmqpContainer configuration)