Class JmsOutboundGatewaySpec.ReplyContainerSpec

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<JmsOutboundGatewaySpec.ReplyContainerSpec, JmsOutboundGateway.ReplyContainerProperties>

org.springframework.integration.jms.dsl.JmsOutboundGatewaySpec.ReplyContainerSpec

All Implemented Interfaces:

DisposableBean, FactoryBean<JmsOutboundGateway.ReplyContainerProperties>, InitializingBean, Lifecycle, Phased, SmartLifecycle

Enclosing class:

JmsOutboundGatewaySpec

public class JmsOutboundGatewaySpec.ReplyContainerSpec
extends IntegrationComponentSpec<JmsOutboundGatewaySpec.ReplyContainerSpec, JmsOutboundGateway.ReplyContainerProperties>

An IntegrationComponentSpec for JmsOutboundGateway.ReplyContainerProperties.

Since:

5.0

Author:

Artem Bilan

Field Summary

Fields inherited from class IntegrationComponentSpec

logger, PARSER, target

Fields inherited from interface FactoryBean

OBJECT_TYPE_ATTRIBUTE

Fields inherited from interface SmartLifecycle

DEFAULT_PHASE

Method Summary

Modifier and Type	Method	Description
JmsOutboundGatewaySpec.ReplyContainerSpec	cacheLevel(Integer cacheLevel)
JmsOutboundGatewaySpec.ReplyContainerSpec	concurrentConsumers(Integer concurrentConsumers)
JmsOutboundGatewaySpec.ReplyContainerSpec	idleConsumerLimit(Integer idleConsumerLimit)
JmsOutboundGatewaySpec.ReplyContainerSpec	idleReplyContainerTimeout(long idleReplyContainerTimeout)
JmsOutboundGatewaySpec.ReplyContainerSpec	idleTaskExecutionLimit(Integer idleTaskExecutionLimit)
JmsOutboundGatewaySpec.ReplyContainerSpec	maxConcurrentConsumers(Integer maxConcurrentConsumers)
JmsOutboundGatewaySpec.ReplyContainerSpec	maxMessagesPerTask(Integer maxMessagesPerTask)
JmsOutboundGatewaySpec.ReplyContainerSpec	receiveTimeout(Long receiveTimeout)
JmsOutboundGatewaySpec.ReplyContainerSpec	recoveryInterval(Long recoveryInterval)
JmsOutboundGatewaySpec.ReplyContainerSpec	sessionAcknowledgeMode(Integer sessionAcknowledgeMode)
JmsOutboundGatewaySpec.ReplyContainerSpec	sessionTransacted(Boolean sessionTransacted)
JmsOutboundGatewaySpec.ReplyContainerSpec	taskExecutor(Executor taskExecutor)

Methods inherited from class IntegrationComponentSpec

_this, afterPropertiesSet, destroy, doGet, getId, getObject, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop

Methods inherited from class Object

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

Methods inherited from interface FactoryBean

isSingleton

Methods inherited from interface SmartLifecycle

isPauseable

Method Details

sessionTransacted

public JmsOutboundGatewaySpec.ReplyContainerSpec sessionTransacted(Boolean sessionTransacted)

Parameters:

sessionTransacted - the sessionTransacted.

Returns:

the current JmsOutboundGatewaySpec.ReplyContainerSpec.

See Also:

• AbstractPollingMessageListenerContainer.setSessionTransacted(boolean)

sessionAcknowledgeMode

public JmsOutboundGatewaySpec.ReplyContainerSpec sessionAcknowledgeMode(Integer sessionAcknowledgeMode)

Parameters:

sessionAcknowledgeMode - the acknowledgement mode constant

Returns:

the current JmsOutboundGatewaySpec.ReplyContainerSpec.

See Also:

• etc.

receiveTimeout

public JmsOutboundGatewaySpec.ReplyContainerSpec receiveTimeout(Long receiveTimeout)

Parameters:

receiveTimeout - the receiveTimeout.

Returns:

the current JmsOutboundGatewaySpec.ReplyContainerSpec.

See Also:

• AbstractPollingMessageListenerContainer.setReceiveTimeout(long)

recoveryInterval

public JmsOutboundGatewaySpec.ReplyContainerSpec recoveryInterval(Long recoveryInterval)

Parameters:

recoveryInterval - the recoveryInterval.

Returns:

the current {ReplyContainerSpec}.

See Also:

• DefaultMessageListenerContainer.setRecoveryInterval(long)

cacheLevel

public JmsOutboundGatewaySpec.ReplyContainerSpec cacheLevel(Integer cacheLevel)

Parameters:

cacheLevel - the value for org.springframework.jms.listener.DefaultMessageListenerContainer.cacheLevel.

Returns:

the current {ReplyContainerSpec}.

See Also:

• DefaultMessageListenerContainer.setCacheLevel(int)

concurrentConsumers

public JmsOutboundGatewaySpec.ReplyContainerSpec concurrentConsumers(Integer concurrentConsumers)

Parameters:

concurrentConsumers - the concurrentConsumers.

Returns:

the current {ReplyContainerSpec}.

See Also:

• DefaultMessageListenerContainer.setConcurrentConsumers(int)

maxConcurrentConsumers

public JmsOutboundGatewaySpec.ReplyContainerSpec maxConcurrentConsumers(Integer maxConcurrentConsumers)

Parameters:

maxConcurrentConsumers - the maxConcurrentConsumers.

Returns:

the current {ReplyContainerSpec}.

See Also:

• DefaultMessageListenerContainer.setMaxConcurrentConsumers(int)

maxMessagesPerTask

public JmsOutboundGatewaySpec.ReplyContainerSpec maxMessagesPerTask(Integer maxMessagesPerTask)

Parameters:

maxMessagesPerTask - the maxMessagesPerTask.

Returns:

the current {ReplyContainerSpec}.

See Also:

• DefaultMessageListenerContainer.setMaxMessagesPerTask(int)

idleConsumerLimit

public JmsOutboundGatewaySpec.ReplyContainerSpec idleConsumerLimit(Integer idleConsumerLimit)

Parameters:

idleConsumerLimit - the idleConsumerLimit.

Returns:

the current {ReplyContainerSpec}.

See Also:

• DefaultMessageListenerContainer.setIdleConsumerLimit(int)

idleTaskExecutionLimit

public JmsOutboundGatewaySpec.ReplyContainerSpec idleTaskExecutionLimit(Integer idleTaskExecutionLimit)

Parameters:

idleTaskExecutionLimit - the idleTaskExecutionLimit.

Returns:

the current {ReplyContainerSpec}.

See Also:

• DefaultMessageListenerContainer.setIdleTaskExecutionLimit(int)

taskExecutor

public JmsOutboundGatewaySpec.ReplyContainerSpec taskExecutor(Executor taskExecutor)

Parameters:

taskExecutor - the taskExecutor.

Returns:

the current {ReplyContainerSpec}.

See Also:

• DefaultMessageListenerContainer.setTaskExecutor(Executor)

idleReplyContainerTimeout

public JmsOutboundGatewaySpec.ReplyContainerSpec idleReplyContainerTimeout(long idleReplyContainerTimeout)

Parameters:

idleReplyContainerTimeout - the timeout in seconds.

Returns:

the current {ReplyContainerSpec}.

See Also:

• JmsOutboundGateway.setIdleReplyContainerTimeout(long)