Class SimpleRabbitListenerContainerFactory
java.lang.Object
org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory<C>
org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory<SimpleMessageListenerContainer>
org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
- All Implemented Interfaces:
RabbitListenerContainerFactory<SimpleMessageListenerContainer>,Aware,ApplicationContextAware,ApplicationEventPublisherAware
public class SimpleRabbitListenerContainerFactory
extends AbstractRabbitListenerContainerFactory<SimpleMessageListenerContainer>
A
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.
- Since:
- 1.4
- Author:
- Stephane Nicoll, Gary Russell, Artem Bilan, Dustin Schultz
-
Field Summary
Fields inherited from class org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory
counter, logger -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected SimpleMessageListenerContainerCreate an empty container instance.protected voidinitializeContainer(SimpleMessageListenerContainer instance, RabbitListenerEndpoint endpoint) Further initialize the specified container.voidsetBatchSize(Integer batchSize) voidsetConcurrentConsumers(Integer concurrency) voidsetConsecutiveActiveTrigger(Integer minConsecutiveActive) voidsetConsecutiveIdleTrigger(Integer minConsecutiveIdle) voidsetConsumerBatchEnabled(boolean consumerBatchEnabled) Set to true to present a list of messages based on thesetBatchSize(Integer), if the listener supports it.voidsetMaxConcurrentConsumers(Integer maxConcurrency) voidsetReceiveTimeout(Long receiveTimeout) voidsetStartConsumerMinInterval(Long minStartInterval) voidsetStopConsumerMinInterval(Long minStopInterval) Methods inherited from class org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory
createListenerContainer, setAcknowledgeMode, setAfterReceivePostProcessors, setApplicationContext, setApplicationEventPublisher, setAutoStartup, setBatchingStrategy, setBatchListener, setChannelTransacted, setConnectionFactory, setConsumerTagStrategy, setContainerCustomizer, setDeBatchingEnabled, setErrorHandler, setFailedDeclarationRetryInterval, setGlobalQos, setIdleEventInterval, setMessageConverter, setMismatchedQueuesFatal, setMissingQueuesFatal, setPhase, setPrefetchCount, setRecoveryBackOff, setRecoveryInterval, setTaskExecutor, setTransactionManagerMethods inherited from class org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory
applyCommonOverrides, getAdviceChain, getDefaultRequeueRejected, setAdviceChain, setBeforeSendReplyPostProcessors, setDefaultRequeueRejected, setReplyRecoveryCallback, setRetryTemplateMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory
createListenerContainer
-
Constructor Details
-
SimpleRabbitListenerContainerFactory
public SimpleRabbitListenerContainerFactory()
-
-
Method Details
-
setBatchSize
- Parameters:
batchSize- the batch size.- Since:
- 2.2
- See Also:
-
setConcurrentConsumers
- Parameters:
concurrency- the minimum number of consumers to create.- See Also:
-
setMaxConcurrentConsumers
- Parameters:
maxConcurrency- the maximum number of consumers.- See Also:
-
setStartConsumerMinInterval
- Parameters:
minStartInterval- The minimum interval between new consumer starts.- See Also:
-
setStopConsumerMinInterval
- Parameters:
minStopInterval- The minimum interval between consumer stops.- See Also:
-
setConsecutiveActiveTrigger
- Parameters:
minConsecutiveActive- The number of consecutive receives to trigger a new consumer.- See Also:
-
setConsecutiveIdleTrigger
- Parameters:
minConsecutiveIdle- The number of consecutive timeouts to trigger stopping a consumer.- See Also:
-
setReceiveTimeout
- Parameters:
receiveTimeout- the timeout.- See Also:
-
setConsumerBatchEnabled
public void setConsumerBatchEnabled(boolean consumerBatchEnabled) Set to true to present a list of messages based on thesetBatchSize(Integer), if the listener supports it.- Parameters:
consumerBatchEnabled- true to create message batches in the container.- Since:
- 2.2
- See Also:
-
createContainerInstance
Description copied from class:AbstractRabbitListenerContainerFactoryCreate an empty container instance.- Specified by:
createContainerInstancein classAbstractRabbitListenerContainerFactory<SimpleMessageListenerContainer>- Returns:
- the new container instance.
-
initializeContainer
protected void initializeContainer(SimpleMessageListenerContainer instance, RabbitListenerEndpoint endpoint) Description copied from class:AbstractRabbitListenerContainerFactoryFurther initialize the specified container.Subclasses can inherit from this method to apply extra configuration if necessary.
- Overrides:
initializeContainerin classAbstractRabbitListenerContainerFactory<SimpleMessageListenerContainer>- Parameters:
instance- the container instance to configure.endpoint- the endpoint.
-