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,SimpleMessageListenerContainer>
org.springframework.integration.amqp.dsl.SimpleMessageListenerContainerSpec
- All Implemented Interfaces:
Aware
,BeanClassLoaderAware
,BeanFactoryAware
,DisposableBean
,FactoryBean<SimpleMessageListenerContainer>
,InitializingBean
,Lifecycle
,Phased
,SmartLifecycle
public class SimpleMessageListenerContainerSpec extends AbstractMessageListenerContainerSpec<SimpleMessageListenerContainerSpec,SimpleMessageListenerContainer>
Spec for a
SimpleMessageListenerContainer
.- Since:
- 5.0
- Author:
- Gary Russell, Artem Bilan
-
Field Summary
Fields Modifier and Type Field Description protected SimpleMessageListenerContainer
listenerContainer
Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
PARSER, target
-
Constructor Summary
Constructors Constructor Description SimpleMessageListenerContainerSpec(SimpleMessageListenerContainer listenerContainer)
-
Method Summary
Modifier and Type Method Description SimpleMessageListenerContainerSpec
batchSize(int batchSize)
The batch size to use.SimpleMessageListenerContainerSpec
concurrentConsumers(int concurrentConsumers)
SimpleMessageListenerContainerSpec
consecutiveActiveTrigger(int consecutiveActiveTrigger)
SimpleMessageListenerContainerSpec
consecutiveIdleTrigger(int consecutiveIdleTrigger)
SimpleMessageListenerContainerSpec
consumerBatchEnabled(boolean enabled)
Set to true to enable batching of consumed messages.SimpleMessageListenerContainerSpec
maxConcurrentConsumers(int maxConcurrentConsumers)
SimpleMessageListenerContainerSpec
receiveTimeout(long receiveTimeout)
SimpleMessageListenerContainerSpec
startConsumerMinInterval(long startConsumerMinInterval)
SimpleMessageListenerContainerSpec
stopConsumerMinInterval(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, transactionManager
Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop
Methods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
-
Field Details
-
Constructor Details
-
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
-