C - the container type.public abstract class AbstractRabbitListenerContainerFactory<C extends AbstractMessageListenerContainer> extends Object implements RabbitListenerContainerFactory<C>, ApplicationContextAware, ApplicationEventPublisherAware
RabbitListenerContainerFactory for Spring's base container implementation.AbstractMessageListenerContainer| Modifier and Type | Field and Description |
|---|---|
protected AtomicInteger |
counter |
protected org.apache.commons.logging.Log |
logger |
| Constructor and Description |
|---|
AbstractRabbitListenerContainerFactory() |
protected final org.apache.commons.logging.Log logger
protected final AtomicInteger counter
public AbstractRabbitListenerContainerFactory()
public void setConnectionFactory(ConnectionFactory connectionFactory)
connectionFactory - The connection factory.RabbitAccessor.setConnectionFactory(ConnectionFactory)public void setErrorHandler(ErrorHandler errorHandler)
errorHandler - The error handler.AbstractMessageListenerContainer.setErrorHandler(org.springframework.util.ErrorHandler)public void setMessageConverter(MessageConverter messageConverter)
messageConverter - the message converter to useAbstractMessageListenerContainer.setMessageConverter(MessageConverter)public void setAcknowledgeMode(AcknowledgeMode acknowledgeMode)
acknowledgeMode - the acknowledge mode to set. Defaults to AcknowledgeMode.AUTOAbstractMessageListenerContainer.setAcknowledgeMode(AcknowledgeMode)public void setChannelTransacted(Boolean channelTransacted)
channelTransacted - the flag value to setRabbitAccessor.setChannelTransacted(boolean)public void setTaskExecutor(Executor taskExecutor)
taskExecutor - the Executor to use.AbstractMessageListenerContainer.setTaskExecutor(java.util.concurrent.Executor)public void setTransactionManager(PlatformTransactionManager transactionManager)
transactionManager - the PlatformTransactionManager to use.AbstractMessageListenerContainer.setTransactionManager(org.springframework.transaction.PlatformTransactionManager)public void setPrefetchCount(Integer prefetch)
prefetch - the prefetch countAbstractMessageListenerContainer.setPrefetchCount(int)public void setDefaultRequeueRejected(Boolean requeueRejected)
requeueRejected - true to reject by default.AbstractMessageListenerContainer.setDefaultRequeueRejected(boolean)public void setAdviceChain(Advice... adviceChain)
adviceChain - the advice chain to set.AbstractMessageListenerContainer.setAdviceChain(org.aopalliance.aop.Advice...)public void setRecoveryInterval(Long recoveryInterval)
recoveryInterval - The recovery interval.AbstractMessageListenerContainer.setRecoveryInterval(long)public void setRecoveryBackOff(BackOff recoveryBackOff)
recoveryBackOff - The BackOff to recover.AbstractMessageListenerContainer.setRecoveryBackOff(BackOff)public void setMissingQueuesFatal(Boolean missingQueuesFatal)
missingQueuesFatal - the missingQueuesFatal to set.SimpleMessageListenerContainer.setMissingQueuesFatal(boolean)public void setMismatchedQueuesFatal(Boolean mismatchedQueuesFatal)
mismatchedQueuesFatal - the mismatchedQueuesFatal to set.AbstractMessageListenerContainer.setMismatchedQueuesFatal(boolean)public void setConsumerTagStrategy(ConsumerTagStrategy consumerTagStrategy)
consumerTagStrategy - the consumerTagStrategy to setAbstractMessageListenerContainer.setConsumerTagStrategy(ConsumerTagStrategy)public void setIdleEventInterval(Long idleEventInterval)
idleEventInterval - the interval.public void setFailedDeclarationRetryInterval(Long failedDeclarationRetryInterval)
public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
setApplicationEventPublisher in interface ApplicationEventPublisherAwarepublic void setApplicationContext(ApplicationContext applicationContext) throws BeansException
setApplicationContext in interface ApplicationContextAwareBeansExceptionpublic void setAutoStartup(Boolean autoStartup)
autoStartup - true for auto startup.AbstractMessageListenerContainer.setAutoStartup(boolean)public void setPhase(int phase)
phase - The phase.AbstractMessageListenerContainer.setPhase(int)public C createListenerContainer(RabbitListenerEndpoint endpoint)
RabbitListenerContainerFactoryMessageListenerContainer for the given RabbitListenerEndpoint.createListenerContainer in interface RabbitListenerContainerFactory<C extends AbstractMessageListenerContainer>endpoint - the endpoint to configureprotected abstract C createContainerInstance()
protected void initializeContainer(C instance, RabbitListenerEndpoint endpoint)
Subclasses can inherit from this method to apply extra configuration if necessary.
instance - the container instance to configure.endpoint - the endpoint.