public class SimpleRabbitListenerContainerFactory extends AbstractRabbitListenerContainerFactory<SimpleMessageListenerContainer> implements org.springframework.context.ApplicationContextAware, org.springframework.context.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() |
| Modifier and Type | Method and Description |
|---|---|
protected SimpleMessageListenerContainer |
createContainerInstance()
Create an empty container instance.
|
protected void |
initializeContainer(SimpleMessageListenerContainer instance)
Further initialize the specified container.
|
void |
setAdviceChain(org.aopalliance.aop.Advice... adviceChain) |
void |
setApplicationContext(org.springframework.context.ApplicationContext applicationContext) |
void |
setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher) |
void |
setConcurrentConsumers(java.lang.Integer concurrency) |
void |
setConsecutiveActiveTrigger(java.lang.Integer minConsecutiveActive) |
void |
setConsecutiveIdleTrigger(java.lang.Integer minConsecutiveIdle) |
void |
setConsumerTagStrategy(org.springframework.amqp.support.ConsumerTagStrategy consumerTagStrategy) |
void |
setDefaultRequeueRejected(java.lang.Boolean requeueRejected) |
void |
setIdleEventInterval(java.lang.Long idleEventInterval)
How often to publish idle container events.
|
void |
setMaxConcurrentConsumers(java.lang.Integer maxConcurrency) |
void |
setMismatchedQueuesFatal(java.lang.Boolean mismatchedQueuesFatal) |
void |
setMissingQueuesFatal(java.lang.Boolean missingQueuesFatal) |
void |
setPrefetchCount(java.lang.Integer prefetch) |
void |
setReceiveTimeout(java.lang.Long receiveTimeout) |
void |
setRecoveryBackOff(org.springframework.util.backoff.BackOff recoveryBackOff) |
void |
setRecoveryInterval(java.lang.Long recoveryInterval) |
void |
setStartConsumerMinInterval(java.lang.Long minStartInterval) |
void |
setStopConsumerMinInterval(java.lang.Long minStopInterval) |
void |
setTaskExecutor(java.util.concurrent.Executor taskExecutor) |
void |
setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) |
void |
setTxSize(java.lang.Integer txSize) |
createListenerContainer, setAcknowledgeMode, setAutoStartup, setChannelTransacted, setConnectionFactory, setErrorHandler, setMessageConverter, setPhasepublic SimpleRabbitListenerContainerFactory()
public void setTaskExecutor(java.util.concurrent.Executor taskExecutor)
taskExecutor - the Executor to use.SimpleMessageListenerContainer.setTaskExecutor(java.util.concurrent.Executor)public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
transactionManager - the PlatformTransactionManager to use.SimpleMessageListenerContainer.setTransactionManager(org.springframework.transaction.PlatformTransactionManager)public void setTxSize(java.lang.Integer txSize)
txSize - the transaction size.SimpleMessageListenerContainer.setTxSize(int)public void setConcurrentConsumers(java.lang.Integer concurrency)
concurrency - the minimum number of consumers to create.SimpleMessageListenerContainer.setConcurrentConsumers(int)public void setMaxConcurrentConsumers(java.lang.Integer maxConcurrency)
maxConcurrency - the maximum number of consumers.SimpleMessageListenerContainer.setMaxConcurrentConsumers(int)public void setStartConsumerMinInterval(java.lang.Long minStartInterval)
minStartInterval - The minimum interval between new consumer starts.SimpleMessageListenerContainer.setStartConsumerMinInterval(long)public void setStopConsumerMinInterval(java.lang.Long minStopInterval)
minStopInterval - The minimum interval between consumer stops.SimpleMessageListenerContainer.setStopConsumerMinInterval(long)public void setConsecutiveActiveTrigger(java.lang.Integer minConsecutiveActive)
minConsecutiveActive - The number of consecutive receives to trigger a new consumer.SimpleMessageListenerContainer.setConsecutiveActiveTrigger(int)public void setConsecutiveIdleTrigger(java.lang.Integer minConsecutiveIdle)
minConsecutiveIdle - The number of consecutive timeouts to trigger stopping a consumer.SimpleMessageListenerContainer.setConsecutiveIdleTrigger(int)public void setPrefetchCount(java.lang.Integer prefetch)
prefetch - the prefetch countSimpleMessageListenerContainer.setPrefetchCount(int)public void setReceiveTimeout(java.lang.Long receiveTimeout)
receiveTimeout - the timeout.SimpleMessageListenerContainer.setReceiveTimeout(long)public void setDefaultRequeueRejected(java.lang.Boolean requeueRejected)
requeueRejected - true to reject by default.SimpleMessageListenerContainer.setDefaultRequeueRejected(boolean)public void setAdviceChain(org.aopalliance.aop.Advice... adviceChain)
adviceChain - the advice chain to set.SimpleMessageListenerContainer.setAdviceChain(org.aopalliance.aop.Advice[])public void setRecoveryInterval(java.lang.Long recoveryInterval)
recoveryInterval - The recovery interval.SimpleMessageListenerContainer.setRecoveryInterval(long)public void setRecoveryBackOff(org.springframework.util.backoff.BackOff recoveryBackOff)
recoveryBackOff - The BackOff to recover.SimpleMessageListenerContainer.setRecoveryBackOff(BackOff)public void setMissingQueuesFatal(java.lang.Boolean missingQueuesFatal)
missingQueuesFatal - the missingQueuesFatal to set.SimpleMessageListenerContainer.setMissingQueuesFatal(boolean)public void setMismatchedQueuesFatal(java.lang.Boolean mismatchedQueuesFatal)
mismatchedQueuesFatal - the mismatchedQueuesFatal to set.SimpleMessageListenerContainer.setMismatchedQueuesFatal(boolean)public void setConsumerTagStrategy(org.springframework.amqp.support.ConsumerTagStrategy consumerTagStrategy)
consumerTagStrategy - the consumerTagStrategy to setSimpleMessageListenerContainer.setConsumerTagStrategy(ConsumerTagStrategy)public void setIdleEventInterval(java.lang.Long idleEventInterval)
idleEventInterval - the interval.public void setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)
setApplicationEventPublisher in interface org.springframework.context.ApplicationEventPublisherAwarepublic void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
throws org.springframework.beans.BeansException
setApplicationContext in interface org.springframework.context.ApplicationContextAwareorg.springframework.beans.BeansExceptionprotected SimpleMessageListenerContainer createContainerInstance()
AbstractRabbitListenerContainerFactorycreateContainerInstance in class AbstractRabbitListenerContainerFactory<SimpleMessageListenerContainer>protected void initializeContainer(SimpleMessageListenerContainer instance)
AbstractRabbitListenerContainerFactorySubclasses can inherit from this method to apply extra configuration if necessary.
initializeContainer in class AbstractRabbitListenerContainerFactory<SimpleMessageListenerContainer>instance - the containe instance to configure.