public class SimpleRabbitListenerContainerFactory extends AbstractRabbitListenerContainerFactory<SimpleMessageListenerContainer> implements ApplicationContextAware, ApplicationEventPublisherAware
RabbitListenerContainerFactory
implementation to build a regular
SimpleMessageListenerContainer
.
This should be the default for most users and a good transition paths for those that are used to build such container definition manually.
counter, logger
Constructor and Description |
---|
SimpleRabbitListenerContainerFactory() |
createListenerContainer, setAcknowledgeMode, setAutoStartup, setChannelTransacted, setConnectionFactory, setErrorHandler, setMessageConverter, setPhase
public SimpleRabbitListenerContainerFactory()
public void setTaskExecutor(Executor taskExecutor)
taskExecutor
- the Executor
to use.SimpleMessageListenerContainer.setTaskExecutor(java.util.concurrent.Executor)
public void setTransactionManager(PlatformTransactionManager transactionManager)
transactionManager
- the PlatformTransactionManager
to use.SimpleMessageListenerContainer.setTransactionManager(org.springframework.transaction.PlatformTransactionManager)
public void setTxSize(Integer txSize)
txSize
- the transaction size.SimpleMessageListenerContainer.setTxSize(int)
public void setConcurrentConsumers(Integer concurrency)
concurrency
- the minimum number of consumers to create.SimpleMessageListenerContainer.setConcurrentConsumers(int)
public void setMaxConcurrentConsumers(Integer maxConcurrency)
maxConcurrency
- the maximum number of consumers.SimpleMessageListenerContainer.setMaxConcurrentConsumers(int)
public void setStartConsumerMinInterval(Long minStartInterval)
minStartInterval
- The minimum interval between new consumer starts.SimpleMessageListenerContainer.setStartConsumerMinInterval(long)
public void setStopConsumerMinInterval(Long minStopInterval)
minStopInterval
- The minimum interval between consumer stops.SimpleMessageListenerContainer.setStopConsumerMinInterval(long)
public void setConsecutiveActiveTrigger(Integer minConsecutiveActive)
minConsecutiveActive
- The number of consecutive receives to trigger a new consumer.SimpleMessageListenerContainer.setConsecutiveActiveTrigger(int)
public void setConsecutiveIdleTrigger(Integer minConsecutiveIdle)
minConsecutiveIdle
- The number of consecutive timeouts to trigger stopping a consumer.SimpleMessageListenerContainer.setConsecutiveIdleTrigger(int)
public void setPrefetchCount(Integer prefetch)
prefetch
- the prefetch countSimpleMessageListenerContainer.setPrefetchCount(int)
public void setReceiveTimeout(Long receiveTimeout)
receiveTimeout
- the timeout.SimpleMessageListenerContainer.setReceiveTimeout(long)
public void setDefaultRequeueRejected(Boolean requeueRejected)
requeueRejected
- true to reject by default.SimpleMessageListenerContainer.setDefaultRequeueRejected(boolean)
public void setAdviceChain(Advice... adviceChain)
adviceChain
- the advice chain to set.SimpleMessageListenerContainer.setAdviceChain(org.aopalliance.aop.Advice...)
public void setRecoveryInterval(Long recoveryInterval)
recoveryInterval
- The recovery interval.SimpleMessageListenerContainer.setRecoveryInterval(long)
public void setRecoveryBackOff(BackOff recoveryBackOff)
recoveryBackOff
- The BackOff to recover.SimpleMessageListenerContainer.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.SimpleMessageListenerContainer.setMismatchedQueuesFatal(boolean)
public void setConsumerTagStrategy(ConsumerTagStrategy consumerTagStrategy)
consumerTagStrategy
- the consumerTagStrategy to setSimpleMessageListenerContainer.setConsumerTagStrategy(ConsumerTagStrategy)
public void setIdleEventInterval(Long idleEventInterval)
idleEventInterval
- the interval.public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
setApplicationEventPublisher
in interface ApplicationEventPublisherAware
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
setApplicationContext
in interface ApplicationContextAware
BeansException
protected SimpleMessageListenerContainer createContainerInstance()
AbstractRabbitListenerContainerFactory
createContainerInstance
in class AbstractRabbitListenerContainerFactory<SimpleMessageListenerContainer>
protected void initializeContainer(SimpleMessageListenerContainer instance)
AbstractRabbitListenerContainerFactory
Subclasses can inherit from this method to apply extra configuration if necessary.
initializeContainer
in class AbstractRabbitListenerContainerFactory<SimpleMessageListenerContainer>
instance
- the containe instance to configure.