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, wait
createListenerContainer
public abstract C createListenerContainer(RabbitListenerEndpoint endpoint)
RabbitListenerContainerFactory
MessageListenerContainer
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)