Class JmsDefaultListenerContainerSpec
java.lang.Object
org.springframework.integration.dsl.IntegrationComponentSpec<S,A>
org.springframework.integration.jms.dsl.JmsDestinationAccessorSpec<S,C>
org.springframework.integration.jms.dsl.JmsListenerContainerSpec<JmsDefaultListenerContainerSpec,DefaultMessageListenerContainer>
org.springframework.integration.jms.dsl.JmsDefaultListenerContainerSpec
- All Implemented Interfaces:
DisposableBean
,FactoryBean<DefaultMessageListenerContainer>
,InitializingBean
,Lifecycle
,Phased
,SmartLifecycle
public class JmsDefaultListenerContainerSpec
extends JmsListenerContainerSpec<JmsDefaultListenerContainerSpec,DefaultMessageListenerContainer>
A
DefaultMessageListenerContainer
specific JmsListenerContainerSpec
extension.- Since:
- 5.0
- Author:
- Artem Bilan
-
Field Summary
Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
logger, PARSER, target
Fields inherited from interface org.springframework.beans.factory.FactoryBean
OBJECT_TYPE_ATTRIBUTE
Fields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionSpecify aBackOff
.cacheLevel
(int cacheLevel) Specify the level of caching that this listener container is allowed to apply.cacheLevelName
(String constantName) Specify the level of caching that this listener container is allowed to apply, in the form of the name of the corresponding constant: e.g.concurrency
(String concurrency) The concurrency to use.concurrentConsumers
(int concurrentConsumers) The concurrent consumers number to use.idleConsumerLimit
(int idleConsumerLimit) The max for concurrent consumers number to use.idleTaskExecutionLimit
(int idleTaskExecutionLimit) The the limit for idle task.maxConcurrentConsumers
(int maxConcurrentConsumers) The max for concurrent consumers number to use.maxMessagesPerTask
(int maxMessagesPerTask) The max messages per task.receiveTimeout
(long receiveTimeout) A receive timeout.recoveryInterval
(long recoveryInterval) Specify a recovery interval.taskExecutor
(Executor taskExecutor) Specify anExecutor
.transactionManager
(PlatformTransactionManager transactionManager) APlatformTransactionManager
reference.transactionName
(String transactionName) A name for transaction.transactionTimeout
(int transactionTimeout) A transaction timeout.Methods inherited from class org.springframework.integration.jms.dsl.JmsListenerContainerSpec
acceptMessagesWhileStopping, clientId, durableSubscriptionName, errorHandler, exceptionListener, exposeListenerSession, messageSelector, subscriptionDurable, subscriptionShared
Methods inherited from class org.springframework.integration.jms.dsl.JmsDestinationAccessorSpec
connectionFactory, destinationResolver, id, pubSubDomain, sessionAcknowledgeMode, sessionAcknowledgeModeName, sessionTransacted
Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, afterPropertiesSet, destroy, doGet, getId, getObject, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.springframework.beans.factory.FactoryBean
isSingleton
-
Constructor Details
-
JmsDefaultListenerContainerSpec
protected JmsDefaultListenerContainerSpec()
-
-
Method Details
-
taskExecutor
Specify anExecutor
.- Parameters:
taskExecutor
- theExecutor
to use.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
-
backOff
Specify aBackOff
.- Parameters:
backOff
- theBackOff
to use.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
-
recoveryInterval
Specify a recovery interval.- Parameters:
recoveryInterval
- the recovery interval to use.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
-
cacheLevelName
Specify the level of caching that this listener container is allowed to apply, in the form of the name of the corresponding constant: e.g. "CACHE_CONNECTION".- Parameters:
constantName
- the cache level constant name.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
-
cacheLevel
Specify the level of caching that this listener container is allowed to apply.- Parameters:
cacheLevel
- the level of caching.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
-
concurrency
The concurrency to use.- Parameters:
concurrency
- the concurrency.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
-
concurrentConsumers
The concurrent consumers number to use.- Parameters:
concurrentConsumers
- the concurrent consumers count.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
-
maxConcurrentConsumers
The max for concurrent consumers number to use.- Parameters:
maxConcurrentConsumers
- the max concurrent consumers count.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
-
maxMessagesPerTask
The max messages per task.- Parameters:
maxMessagesPerTask
- the max messages per task.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
-
idleConsumerLimit
The max for concurrent consumers number to use.- Parameters:
idleConsumerLimit
- the limit for idle consumer.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
-
idleTaskExecutionLimit
The the limit for idle task.- Parameters:
idleTaskExecutionLimit
- the limit for idle task.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
-
transactionManager
public JmsDefaultListenerContainerSpec transactionManager(PlatformTransactionManager transactionManager) APlatformTransactionManager
reference.- Parameters:
transactionManager
- thePlatformTransactionManager
to use.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
-
transactionName
A name for transaction.- Parameters:
transactionName
- the name for transaction.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
-
transactionTimeout
A transaction timeout.- Parameters:
transactionTimeout
- the transaction timeout.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
-
receiveTimeout
A receive timeout.- Parameters:
receiveTimeout
- the receive timeout.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
-