C - the container type that the factory creates.public abstract class BaseRabbitListenerContainerFactory<C extends MessageListenerContainer> extends Object implements RabbitListenerContainerFactory<C>
| Constructor and Description |
|---|
BaseRabbitListenerContainerFactory() |
| Modifier and Type | Method and 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. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcreateListenerContainerpublic abstract C createListenerContainer(RabbitListenerEndpoint endpoint)
RabbitListenerContainerFactoryMessageListenerContainer for the given
RabbitListenerEndpoint.createListenerContainer in interface RabbitListenerContainerFactory<C extends MessageListenerContainer>endpoint - the endpoint to configure.public void setDefaultRequeueRejected(Boolean requeueRejected)
requeueRejected - true to reject by default.AbstractMessageListenerContainer.setDefaultRequeueRejected(boolean)protected Boolean getDefaultRequeueRejected()
public void setBeforeSendReplyPostProcessors(MessagePostProcessor... postProcessors)
postProcessors - the post processors.AbstractAdaptableMessageListener.setBeforeSendReplyPostProcessors(MessagePostProcessor...)public void setRetryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)
RetryTemplate to use when sending replies; added to each message
listener adapter.retryTemplate - the template.setReplyRecoveryCallback(RecoveryCallback),
AbstractAdaptableMessageListener.setRetryTemplate(RetryTemplate)public void setReplyRecoveryCallback(org.springframework.retry.RecoveryCallback<?> recoveryCallback)
RecoveryCallback to invoke when retries are exhausted. Added to each
message listener adapter. Only used if a retryTemplate is provided.recoveryCallback - the recovery callback.setRetryTemplate(RetryTemplate),
AbstractAdaptableMessageListener.setRecoveryCallback(RecoveryCallback)protected void applyCommonOverrides(@Nullable RabbitListenerEndpoint endpoint, C instance)