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
FieldsModifier and TypeFieldDescriptionprotected final org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainerFields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
PARSER, targetFields inherited from class org.springframework.beans.factory.config.AbstractFactoryBean
loggerFields inherited from interface org.springframework.beans.factory.FactoryBean
OBJECT_TYPE_ATTRIBUTEFields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE -
Constructor Summary
ConstructorsConstructorDescriptionSimpleMessageListenerContainerSpec(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer) -
Method Summary
Modifier and TypeMethodDescriptionbatchSize(int batchSize) The batch size to use.concurrentConsumers(int concurrentConsumers) consecutiveActiveTrigger(int consecutiveActiveTrigger) consecutiveIdleTrigger(int consecutiveIdleTrigger) consumerBatchEnabled(boolean enabled) Set to true to enable batching of consumed messages.maxConcurrentConsumers(int maxConcurrentConsumers) receiveTimeout(long receiveTimeout) startConsumerMinInterval(long startConsumerMinInterval) 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, transactionManagerMethods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stopMethods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
-
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
-