Package org.springframework.integration.jms.dsl

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

Fields inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

logger

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

Modifier	Constructor	Description
protected	JmsDefaultListenerContainerSpec()

Method Summary

Modifier and Type	Method	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.

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JmsDefaultListenerContainerSpec

protected JmsDefaultListenerContainerSpec()

Method Details

taskExecutor

public JmsDefaultListenerContainerSpec taskExecutor(Executor taskExecutor)

Specify an Executor.

Parameters:

taskExecutor - the Executor to use.

Returns:

current JmsDefaultListenerContainerSpec.

See Also:

• DefaultMessageListenerContainer.setTaskExecutor(Executor)

backOff

public JmsDefaultListenerContainerSpec backOff(BackOff backOff)

Specify a BackOff.

Parameters:

backOff - the BackOff to use.

Returns:

current JmsDefaultListenerContainerSpec.

See Also:

• DefaultMessageListenerContainer.setBackOff(BackOff)

recoveryInterval

public JmsDefaultListenerContainerSpec recoveryInterval(long recoveryInterval)

Specify a recovery interval.

Parameters:

recoveryInterval - the recovery interval to use.

Returns:

current JmsDefaultListenerContainerSpec.

See Also:

• DefaultMessageListenerContainer.setRecoveryInterval(long)

cacheLevelName

public 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. "CACHE_CONNECTION".

Parameters:

constantName - the cache level constant name.

Returns:

current JmsDefaultListenerContainerSpec.

See Also:

• cacheLevel(int)
• DefaultMessageListenerContainer.setCacheLevelName(String)

cacheLevel

public JmsDefaultListenerContainerSpec cacheLevel(int 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

public JmsDefaultListenerContainerSpec concurrency(String concurrency)

The concurrency to use.

Parameters:

concurrency - the concurrency.

Returns:

current JmsDefaultListenerContainerSpec.

See Also:

• DefaultMessageListenerContainer.setConcurrency(String)

concurrentConsumers

public JmsDefaultListenerContainerSpec concurrentConsumers(int concurrentConsumers)

The concurrent consumers number to use.

Parameters:

concurrentConsumers - the concurrent consumers count.

Returns:

current JmsDefaultListenerContainerSpec.

See Also:

• DefaultMessageListenerContainer.setConcurrentConsumers(int)

maxConcurrentConsumers

public JmsDefaultListenerContainerSpec maxConcurrentConsumers(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

public JmsDefaultListenerContainerSpec maxMessagesPerTask(int maxMessagesPerTask)

The max messages per task.

Parameters:

maxMessagesPerTask - the max messages per task.

Returns:

current JmsDefaultListenerContainerSpec.

See Also:

• DefaultMessageListenerContainer.setMaxMessagesPerTask(int)

idleConsumerLimit

public JmsDefaultListenerContainerSpec idleConsumerLimit(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

public JmsDefaultListenerContainerSpec idleTaskExecutionLimit(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)

A PlatformTransactionManager reference.

Parameters:

transactionManager - the PlatformTransactionManager to use.

Returns:

current JmsDefaultListenerContainerSpec.

See Also:

• AbstractPollingMessageListenerContainer.setTransactionManager(PlatformTransactionManager)

transactionName

public JmsDefaultListenerContainerSpec transactionName(String transactionName)

A name for transaction.

Parameters:

transactionName - the name for transaction.

Returns:

current JmsDefaultListenerContainerSpec.

See Also:

• AbstractPollingMessageListenerContainer.setTransactionName(String)

transactionTimeout

public JmsDefaultListenerContainerSpec transactionTimeout(int transactionTimeout)

A transaction timeout.

Parameters:

transactionTimeout - the transaction timeout.

Returns:

current JmsDefaultListenerContainerSpec.

See Also:

• AbstractPollingMessageListenerContainer.setTransactionTimeout(int)

receiveTimeout

public JmsDefaultListenerContainerSpec receiveTimeout(long receiveTimeout)

A receive timeout.

Parameters:

receiveTimeout - the receive timeout.

Returns:

current JmsDefaultListenerContainerSpec.

See Also:

• AbstractPollingMessageListenerContainer.setReceiveTimeout(long)