Package org.springframework.amqp.rabbit.config

Class BaseRabbitListenerContainerFactory<C extends MessageListenerContainer>

java.lang.Object

org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory<C>

Type Parameters:

C - the container type that the factory creates.

All Implemented Interfaces:

RabbitListenerContainerFactory<C>

Direct Known Subclasses:

AbstractRabbitListenerContainerFactory, StreamRabbitListenerContainerFactory

public abstract class BaseRabbitListenerContainerFactory<C extends MessageListenerContainer>
extends Object
implements RabbitListenerContainerFactory<C>

Base abstract class for listener container factories.

Since:

2.4

Author:

Gary Russell

Constructor Summary

Constructors

Constructor	Description
BaseRabbitListenerContainerFactory()

Method Summary

Modifier and Type	Method	Description
protected void	applyCommonOverrides(RabbitListenerEndpoint endpoint, C instance)
abstract C	createListenerContainer(RabbitListenerEndpoint endpoint)	Create a MessageListenerContainer for the given RabbitListenerEndpoint.
protected Boolean	getDefaultRequeueRejected()	Return the defaultRequeueRejected.
void	setBeforeSendReplyPostProcessors(MessagePostProcessor... postProcessors)	Set post processors that will be applied before sending replies; added to each message listener adapter.
void	setDefaultRequeueRejected(Boolean requeueRejected)
void	setReplyRecoveryCallback(org.springframework.retry.RecoveryCallback<?> recoveryCallback)	Set a RecoveryCallback to invoke when retries are exhausted.
void	setRetryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)	Set a RetryTemplate to use when sending replies; added to each message listener adapter.

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

createListenerContainer

Constructor Detail

BaseRabbitListenerContainerFactory

public BaseRabbitListenerContainerFactory()

Method Detail

createListenerContainer

public abstract C createListenerContainer(RabbitListenerEndpoint endpoint)

Description copied from interface: RabbitListenerContainerFactory

Create a MessageListenerContainer for the given RabbitListenerEndpoint.

Specified by:

createListenerContainer in interface RabbitListenerContainerFactory<C extends MessageListenerContainer>

Parameters:

endpoint - the endpoint to configure.

Returns:

the created container.

setDefaultRequeueRejected

public void setDefaultRequeueRejected(Boolean requeueRejected)

Parameters:

requeueRejected - true to reject by default.

See Also:

AbstractMessageListenerContainer.setDefaultRequeueRejected(boolean)

getDefaultRequeueRejected

protected Boolean getDefaultRequeueRejected()

Return the defaultRequeueRejected.

Returns:

the defaultRequeueRejected.

setBeforeSendReplyPostProcessors

public void setBeforeSendReplyPostProcessors(MessagePostProcessor... postProcessors)

Set post processors that will be applied before sending replies; added to each message listener adapter.

Parameters:

postProcessors - the post processors.

See Also:

AbstractAdaptableMessageListener.setBeforeSendReplyPostProcessors(MessagePostProcessor...)

setRetryTemplate

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

Set a RetryTemplate to use when sending replies; added to each message listener adapter.

Parameters:

retryTemplate - the template.

See Also:

setReplyRecoveryCallback(RecoveryCallback), AbstractAdaptableMessageListener.setRetryTemplate(RetryTemplate)

setReplyRecoveryCallback

public void setReplyRecoveryCallback(org.springframework.retry.RecoveryCallback<?> recoveryCallback)

Set a RecoveryCallback to invoke when retries are exhausted. Added to each message listener adapter. Only used if a retryTemplate is provided.

Parameters:

recoveryCallback - the recovery callback.

See Also:

setRetryTemplate(RetryTemplate), AbstractAdaptableMessageListener.setRecoveryCallback(RecoveryCallback)

applyCommonOverrides

protected void applyCommonOverrides(@Nullable
                                    RabbitListenerEndpoint endpoint,
                                    C instance)