Class JmsDefaultListenerContainerSpec
java.lang.Object
org.springframework.beans.factory.config.AbstractFactoryBean<T>
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:
Aware
,BeanClassLoaderAware
,BeanFactoryAware
,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
PARSER, target
-
Constructor Summary
Constructors Modifier Constructor Description protected
JmsDefaultListenerContainerSpec()
-
Method Summary
Modifier and Type Method Description JmsDefaultListenerContainerSpec
backOff(BackOff backOff)
Specify aBackOff
.JmsDefaultListenerContainerSpec
cacheLevel(int cacheLevel)
Specify the level of caching that this listener container is allowed to apply.JmsDefaultListenerContainerSpec
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.JmsDefaultListenerContainerSpec
concurrency(String concurrency)
The concurrency to use.JmsDefaultListenerContainerSpec
concurrentConsumers(int concurrentConsumers)
The concurrent consumers number to use.JmsDefaultListenerContainerSpec
idleConsumerLimit(int idleConsumerLimit)
The max for concurrent consumers number to use.JmsDefaultListenerContainerSpec
idleTaskExecutionLimit(int idleTaskExecutionLimit)
The the limit for idle task.JmsDefaultListenerContainerSpec
maxConcurrentConsumers(int maxConcurrentConsumers)
The max for concurrent consumers number to use.JmsDefaultListenerContainerSpec
maxMessagesPerTask(int maxMessagesPerTask)
The max messages per task.JmsDefaultListenerContainerSpec
receiveTimeout(long receiveTimeout)
A receive timeout.JmsDefaultListenerContainerSpec
recoveryInterval(long recoveryInterval)
Specify a recovery interval.JmsDefaultListenerContainerSpec
taskExecutor(Executor taskExecutor)
Specify anExecutor
.JmsDefaultListenerContainerSpec
transactionManager(PlatformTransactionManager transactionManager)
APlatformTransactionManager
reference.JmsDefaultListenerContainerSpec
transactionName(String transactionName)
A name for transaction.JmsDefaultListenerContainerSpec
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, 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
-
Constructor Details
-
JmsDefaultListenerContainerSpec
protected JmsDefaultListenerContainerSpec()
-
-
Method Details
-
taskExecutor
Specify anExecutor
.- Parameters:
taskExecutor
- theExecutor
to use.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
DefaultMessageListenerContainer.setTaskExecutor(Executor)
-
backOff
Specify aBackOff
.- Parameters:
backOff
- theBackOff
to use.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
DefaultMessageListenerContainer.setBackOff(BackOff)
-
recoveryInterval
Specify a recovery interval.- Parameters:
recoveryInterval
- the recovery interval to use.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
DefaultMessageListenerContainer.setRecoveryInterval(long)
-
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(int)
,DefaultMessageListenerContainer.setCacheLevelName(String)
-
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:
DefaultMessageListenerContainer.setCacheLevel(int)
-
concurrency
The concurrency to use.- Parameters:
concurrency
- the concurrency.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
DefaultMessageListenerContainer.setConcurrency(String)
-
concurrentConsumers
The concurrent consumers number to use.- Parameters:
concurrentConsumers
- the concurrent consumers count.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
DefaultMessageListenerContainer.setConcurrentConsumers(int)
-
maxConcurrentConsumers
The max for concurrent consumers number to use.- Parameters:
maxConcurrentConsumers
- the max concurrent consumers count.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
DefaultMessageListenerContainer.setMaxConcurrentConsumers(int)
-
maxMessagesPerTask
The max messages per task.- Parameters:
maxMessagesPerTask
- the max messages per task.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
DefaultMessageListenerContainer.setMaxMessagesPerTask(int)
-
idleConsumerLimit
The max for concurrent consumers number to use.- Parameters:
idleConsumerLimit
- the limit for idle consumer.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
DefaultMessageListenerContainer.setMaxConcurrentConsumers(int)
-
idleTaskExecutionLimit
The the limit for idle task.- Parameters:
idleTaskExecutionLimit
- the limit for idle task.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
DefaultMessageListenerContainer.setIdleTaskExecutionLimit(int)
-
transactionManager
public JmsDefaultListenerContainerSpec transactionManager(PlatformTransactionManager transactionManager)APlatformTransactionManager
reference.- Parameters:
transactionManager
- thePlatformTransactionManager
to use.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
AbstractPollingMessageListenerContainer.setTransactionManager(PlatformTransactionManager)
-
transactionName
A name for transaction.- Parameters:
transactionName
- the name for transaction.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
AbstractPollingMessageListenerContainer.setTransactionName(String)
-
transactionTimeout
A transaction timeout.- Parameters:
transactionTimeout
- the transaction timeout.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
AbstractPollingMessageListenerContainer.setTransactionTimeout(int)
-
receiveTimeout
A receive timeout.- Parameters:
receiveTimeout
- the receive timeout.- Returns:
- current
JmsDefaultListenerContainerSpec
. - See Also:
AbstractPollingMessageListenerContainer.setReceiveTimeout(long)
-