Class SimpleMessageListenerContainerSpec
java.lang.Object
org.springframework.beans.factory.config.AbstractFactoryBean<T>
org.springframework.integration.dsl.IntegrationComponentSpec<S,C>
org.springframework.integration.amqp.dsl.AbstractMessageListenerContainerSpec<SimpleMessageListenerContainerSpec,org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer>
org.springframework.integration.amqp.dsl.SimpleMessageListenerContainerSpec
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanClassLoaderAware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.FactoryBean<org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer>,org.springframework.beans.factory.InitializingBean,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle
public class SimpleMessageListenerContainerSpec extends AbstractMessageListenerContainerSpec<SimpleMessageListenerContainerSpec,org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer>
Spec for a
SimpleMessageListenerContainer.- Since:
- 5.0
-
Field Summary
Fields Modifier and Type Field Description protected org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainerlistenerContainer -
Constructor Summary
Constructors Constructor Description SimpleMessageListenerContainerSpec(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer) -
Method Summary
Modifier and Type Method Description SimpleMessageListenerContainerSpecbatchSize(int batchSize)The batch size to use.SimpleMessageListenerContainerSpecconcurrentConsumers(int concurrentConsumers)SimpleMessageListenerContainerSpecconsecutiveActiveTrigger(int consecutiveActiveTrigger)SimpleMessageListenerContainerSpecconsecutiveIdleTrigger(int consecutiveIdleTrigger)SimpleMessageListenerContainerSpecconsumerBatchEnabled(boolean enabled)Set to true to enable batching of consumed messages.SimpleMessageListenerContainerSpecmaxConcurrentConsumers(int maxConcurrentConsumers)SimpleMessageListenerContainerSpecreceiveTimeout(long receiveTimeout)SimpleMessageListenerContainerSpecstartConsumerMinInterval(long startConsumerMinInterval)SimpleMessageListenerContainerSpecstopConsumerMinInterval(long stopConsumerMinInterval)Methods inherited from class org.springframework.integration.amqp.dsl.AbstractMessageListenerContainerSpec
acknowledgeMode, addQueueNames, addQueues, adviceChain, afterReceivePostProcessors, alwaysRequeueWithTxManagerRollback, autoDeclare, channelTransacted, consumerArguments, consumerTagStrategy, deBatchingEnabled, defaultRequeueRejected, errorHandler, exclusive, exclusiveConsumerExceptionLogger, failedDeclarationRetryInterval, id, idleEventInterval, lookupKeyQualifier, messagePropertiesConverter, mismatchedQueuesFatal, missingQueuesFatal, prefetchCount, recoveryBackOff, recoveryInterval, shutdownTimeout, statefulRetryFatalWithNullMessageId, taskExecutor, transactionAttribute, transactionManagerMethods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop
-
Field Details
-
listenerContainer
protected final org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer
-
-
Constructor Details
-
SimpleMessageListenerContainerSpec
public SimpleMessageListenerContainerSpec(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer)
-
-
Method Details
-
concurrentConsumers
- Parameters:
concurrentConsumers- the concurrentConsumers- Returns:
- the spec.
- See Also:
SimpleMessageListenerContainer.setConcurrentConsumers(int)
-
maxConcurrentConsumers
- Parameters:
maxConcurrentConsumers- the maxConcurrentConsumers.- Returns:
- the spec.
- See Also:
SimpleMessageListenerContainer.setMaxConcurrentConsumers(int)
-
startConsumerMinInterval
- Parameters:
startConsumerMinInterval- the startConsumerMinInterval- Returns:
- the spec.
- See Also:
SimpleMessageListenerContainer.setStartConsumerMinInterval(long)
-
stopConsumerMinInterval
- Parameters:
stopConsumerMinInterval- the stopConsumerMinInterval.- Returns:
- the spec.
- See Also:
SimpleMessageListenerContainer.setStopConsumerMinInterval(long)
-
consecutiveActiveTrigger
- Parameters:
consecutiveActiveTrigger- the consecutiveActiveTrigger.- Returns:
- the spec.
- See Also:
SimpleMessageListenerContainer.setConsecutiveActiveTrigger(int)
-
consecutiveIdleTrigger
- Parameters:
consecutiveIdleTrigger- the consecutiveIdleTrigger.- Returns:
- the spec.
- See Also:
SimpleMessageListenerContainer.setConsecutiveIdleTrigger(int)
-
receiveTimeout
- Parameters:
receiveTimeout- the receiveTimeout- Returns:
- the spec.
- See Also:
SimpleMessageListenerContainer.setReceiveTimeout(long)
-
batchSize
The batch size to use.- Parameters:
batchSize- the batchSize.- Returns:
- the spec.
- Since:
- 5.2
- See Also:
SimpleMessageListenerContainer.setBatchSize(int)
-
consumerBatchEnabled
Set to true to enable batching of consumed messages.- Parameters:
enabled- true to enable.- Returns:
- the spec.
- Since:
- 5.3
-