public class JmsDefaultListenerContainerSpec extends JmsListenerContainerSpec<JmsDefaultListenerContainerSpec,DefaultMessageListenerContainer>
DefaultMessageListenerContainer
specific JmsListenerContainerSpec
extension.PARSER, target
logger
DEFAULT_PHASE
OBJECT_TYPE_ATTRIBUTE
Modifier | Constructor and Description |
---|---|
protected |
JmsDefaultListenerContainerSpec() |
Modifier and Type | Method and Description |
---|---|
JmsDefaultListenerContainerSpec |
backOff(BackOff backOff)
Specify a
BackOff . |
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 an
Executor . |
JmsDefaultListenerContainerSpec |
transactionManager(PlatformTransactionManager transactionManager)
A
PlatformTransactionManager reference. |
JmsDefaultListenerContainerSpec |
transactionName(String transactionName)
A name for transaction.
|
JmsDefaultListenerContainerSpec |
transactionTimeout(int transactionTimeout)
A transaction timeout.
|
acceptMessagesWhileStopping, clientId, durableSubscriptionName, errorHandler, exceptionListener, exposeListenerSession, messageSelector, subscriptionDurable, subscriptionShared
connectionFactory, destinationResolver, id, pubSubDomain, sessionAcknowledgeMode, sessionAcknowledgeModeName, sessionTransacted
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
public JmsDefaultListenerContainerSpec taskExecutor(Executor taskExecutor)
Executor
.taskExecutor
- the Executor
to use.JmsDefaultListenerContainerSpec
.DefaultMessageListenerContainer.setTaskExecutor(Executor)
public JmsDefaultListenerContainerSpec backOff(BackOff backOff)
BackOff
.backOff
- the BackOff
to use.JmsDefaultListenerContainerSpec
.DefaultMessageListenerContainer.setBackOff(BackOff)
public JmsDefaultListenerContainerSpec recoveryInterval(long recoveryInterval)
recoveryInterval
- the recovery interval to use.JmsDefaultListenerContainerSpec
.DefaultMessageListenerContainer.setRecoveryInterval(long)
public JmsDefaultListenerContainerSpec cacheLevelName(String constantName)
constantName
- the cache level constant name.JmsDefaultListenerContainerSpec
.cacheLevel(int)
,
DefaultMessageListenerContainer.setCacheLevelName(String)
public JmsDefaultListenerContainerSpec cacheLevel(int cacheLevel)
cacheLevel
- the level of caching.JmsDefaultListenerContainerSpec
.DefaultMessageListenerContainer.setCacheLevel(int)
public JmsDefaultListenerContainerSpec concurrency(String concurrency)
concurrency
- the concurrency.JmsDefaultListenerContainerSpec
.DefaultMessageListenerContainer.setConcurrency(String)
public JmsDefaultListenerContainerSpec concurrentConsumers(int concurrentConsumers)
concurrentConsumers
- the concurrent consumers count.JmsDefaultListenerContainerSpec
.DefaultMessageListenerContainer.setConcurrentConsumers(int)
public JmsDefaultListenerContainerSpec maxConcurrentConsumers(int maxConcurrentConsumers)
maxConcurrentConsumers
- the max concurrent consumers count.JmsDefaultListenerContainerSpec
.DefaultMessageListenerContainer.setMaxConcurrentConsumers(int)
public JmsDefaultListenerContainerSpec maxMessagesPerTask(int maxMessagesPerTask)
maxMessagesPerTask
- the max messages per task.JmsDefaultListenerContainerSpec
.DefaultMessageListenerContainer.setMaxMessagesPerTask(int)
public JmsDefaultListenerContainerSpec idleConsumerLimit(int idleConsumerLimit)
idleConsumerLimit
- the limit for idle consumer.JmsDefaultListenerContainerSpec
.DefaultMessageListenerContainer.setMaxConcurrentConsumers(int)
public JmsDefaultListenerContainerSpec idleTaskExecutionLimit(int idleTaskExecutionLimit)
idleTaskExecutionLimit
- the limit for idle task.JmsDefaultListenerContainerSpec
.DefaultMessageListenerContainer.setIdleTaskExecutionLimit(int)
public JmsDefaultListenerContainerSpec transactionManager(PlatformTransactionManager transactionManager)
PlatformTransactionManager
reference.transactionManager
- the PlatformTransactionManager
to use.JmsDefaultListenerContainerSpec
.AbstractPollingMessageListenerContainer.setTransactionManager(PlatformTransactionManager)
public JmsDefaultListenerContainerSpec transactionName(String transactionName)
transactionName
- the name for transaction.JmsDefaultListenerContainerSpec
.AbstractPollingMessageListenerContainer.setTransactionName(String)
public JmsDefaultListenerContainerSpec transactionTimeout(int transactionTimeout)
transactionTimeout
- the transaction timeout.JmsDefaultListenerContainerSpec
.AbstractPollingMessageListenerContainer.setTransactionTimeout(int)
public JmsDefaultListenerContainerSpec receiveTimeout(long receiveTimeout)
receiveTimeout
- the receive timeout.JmsDefaultListenerContainerSpec
.AbstractPollingMessageListenerContainer.setReceiveTimeout(long)