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 protectedJmsDefaultListenerContainerSpec() -
Method Summary
Modifier and Type Method Description JmsDefaultListenerContainerSpecbackOff(BackOff backOff)Specify aBackOff.JmsDefaultListenerContainerSpeccacheLevel(int cacheLevel)Specify the level of caching that this listener container is allowed to apply.JmsDefaultListenerContainerSpeccacheLevelName(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.JmsDefaultListenerContainerSpecconcurrency(String concurrency)The concurrency to use.JmsDefaultListenerContainerSpecconcurrentConsumers(int concurrentConsumers)The concurrent consumers number to use.JmsDefaultListenerContainerSpecidleConsumerLimit(int idleConsumerLimit)The max for concurrent consumers number to use.JmsDefaultListenerContainerSpecidleTaskExecutionLimit(int idleTaskExecutionLimit)The the limit for idle task.JmsDefaultListenerContainerSpecmaxConcurrentConsumers(int maxConcurrentConsumers)The max for concurrent consumers number to use.JmsDefaultListenerContainerSpecmaxMessagesPerTask(int maxMessagesPerTask)The max messages per task.JmsDefaultListenerContainerSpecreceiveTimeout(long receiveTimeout)A receive timeout.JmsDefaultListenerContainerSpecrecoveryInterval(long recoveryInterval)Specify a recovery interval.JmsDefaultListenerContainerSpectaskExecutor(Executor taskExecutor)Specify anExecutor.JmsDefaultListenerContainerSpectransactionManager(PlatformTransactionManager transactionManager)APlatformTransactionManagerreference.JmsDefaultListenerContainerSpectransactionName(String transactionName)A name for transaction.JmsDefaultListenerContainerSpectransactionTimeout(int transactionTimeout)A transaction timeout.Methods inherited from class org.springframework.integration.jms.dsl.JmsListenerContainerSpec
acceptMessagesWhileStopping, clientId, durableSubscriptionName, errorHandler, exceptionListener, exposeListenerSession, messageSelector, subscriptionDurable, subscriptionSharedMethods inherited from class org.springframework.integration.jms.dsl.JmsDestinationAccessorSpec
connectionFactory, destinationResolver, id, pubSubDomain, sessionAcknowledgeMode, sessionAcknowledgeModeName, sessionTransactedMethods 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
-
Constructor Details
-
JmsDefaultListenerContainerSpec
protected JmsDefaultListenerContainerSpec()
-
-
Method Details
-
taskExecutor
Specify anExecutor.- Parameters:
taskExecutor- theExecutorto use.- Returns:
- current
JmsDefaultListenerContainerSpec. - See Also:
DefaultMessageListenerContainer.setTaskExecutor(Executor)
-
backOff
Specify aBackOff.- Parameters:
backOff- theBackOffto 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)APlatformTransactionManagerreference.- Parameters:
transactionManager- thePlatformTransactionManagerto 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)
-