Package org.springframework.integration.amqp.dsl

Class SimpleMessageListenerContainerSpec

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<S,C>

org.springframework.integration.amqp.dsl.MessageListenerContainerSpec<S,C>

org.springframework.integration.amqp.dsl.AbstractMessageListenerContainerSpec<SimpleMessageListenerContainerSpec,SimpleMessageListenerContainer>

org.springframework.integration.amqp.dsl.SimpleMessageListenerContainerSpec

All Implemented Interfaces:

DisposableBean, FactoryBean<SimpleMessageListenerContainer>, InitializingBean, Lifecycle, Phased, SmartLifecycle

public class SimpleMessageListenerContainerSpec
extends AbstractMessageListenerContainerSpec<SimpleMessageListenerContainerSpec,SimpleMessageListenerContainer>

Spec for a SimpleMessageListenerContainer.

Since:

5.0

Author:

Gary Russell, Artem Bilan

Field Summary

Fields

Modifier and Type	Field	Description
protected final SimpleMessageListenerContainer	listenerContainer

Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

logger, PARSER, target

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

Constructor	Description
SimpleMessageListenerContainerSpec(SimpleMessageListenerContainer listenerContainer)

Method Summary

Modifier and Type	Method	Description
SimpleMessageListenerContainerSpec	batchSize(int batchSize)	The batch size to use.
SimpleMessageListenerContainerSpec	concurrentConsumers(int concurrentConsumers)
SimpleMessageListenerContainerSpec	consecutiveActiveTrigger(int consecutiveActiveTrigger)
SimpleMessageListenerContainerSpec	consecutiveIdleTrigger(int consecutiveIdleTrigger)
SimpleMessageListenerContainerSpec	consumerBatchEnabled(boolean enabled)	Set to true to enable batching of consumed messages.
SimpleMessageListenerContainerSpec	maxConcurrentConsumers(int maxConcurrentConsumers)
SimpleMessageListenerContainerSpec	receiveTimeout(long receiveTimeout)
SimpleMessageListenerContainerSpec	startConsumerMinInterval(long startConsumerMinInterval)
SimpleMessageListenerContainerSpec	stopConsumerMinInterval(long stopConsumerMinInterval)

Methods inherited from class org.springframework.integration.amqp.dsl.AbstractMessageListenerContainerSpec

acknowledgeMode, addQueueNames, addQueues, adviceChain, afterReceivePostProcessors, alwaysRequeueWithTxManagerRollback, autoDeclare, channelTransacted, consumerArguments, consumerTagStrategy, deBatchingEnabled, defaultRequeueRejected, errorHandler, exclusive, exclusiveConsumerExceptionLogger, failedDeclarationRetryInterval, id, idleEventInterval, lookupKeyQualifier, messagePropertiesConverter, mismatchedQueuesFatal, missingQueuesFatal, prefetchCount, recoveryBackOff, recoveryInterval, shutdownTimeout, statefulRetryFatalWithNullMessageId, taskExecutor, transactionAttribute, transactionManager

Methods inherited from class org.springframework.integration.amqp.dsl.MessageListenerContainerSpec

queueName

Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.beans.factory.FactoryBean

isSingleton

Field Details

listenerContainer

protected final SimpleMessageListenerContainer listenerContainer

Constructor Details

SimpleMessageListenerContainerSpec

public SimpleMessageListenerContainerSpec(SimpleMessageListenerContainer listenerContainer)

Method Details

concurrentConsumers

public SimpleMessageListenerContainerSpec concurrentConsumers(int concurrentConsumers)

Parameters:

concurrentConsumers - the concurrentConsumers

Returns:

the spec.

See Also:

• SimpleMessageListenerContainer.setConcurrentConsumers(int)

maxConcurrentConsumers

public SimpleMessageListenerContainerSpec maxConcurrentConsumers(int maxConcurrentConsumers)

Parameters:

maxConcurrentConsumers - the maxConcurrentConsumers.

Returns:

the spec.

See Also:

• SimpleMessageListenerContainer.setMaxConcurrentConsumers(int)

startConsumerMinInterval

public SimpleMessageListenerContainerSpec startConsumerMinInterval(long startConsumerMinInterval)

Parameters:

startConsumerMinInterval - the startConsumerMinInterval

Returns:

the spec.

See Also:

• SimpleMessageListenerContainer.setStartConsumerMinInterval(long)

stopConsumerMinInterval

public SimpleMessageListenerContainerSpec stopConsumerMinInterval(long stopConsumerMinInterval)

Parameters:

stopConsumerMinInterval - the stopConsumerMinInterval.

Returns:

the spec.

See Also:

• SimpleMessageListenerContainer.setStopConsumerMinInterval(long)

consecutiveActiveTrigger

public SimpleMessageListenerContainerSpec consecutiveActiveTrigger(int consecutiveActiveTrigger)

Parameters:

consecutiveActiveTrigger - the consecutiveActiveTrigger.

Returns:

the spec.

See Also:

• SimpleMessageListenerContainer.setConsecutiveActiveTrigger(int)

consecutiveIdleTrigger

public SimpleMessageListenerContainerSpec consecutiveIdleTrigger(int consecutiveIdleTrigger)

Parameters:

consecutiveIdleTrigger - the consecutiveIdleTrigger.

Returns:

the spec.

See Also:

• SimpleMessageListenerContainer.setConsecutiveIdleTrigger(int)

receiveTimeout

public SimpleMessageListenerContainerSpec receiveTimeout(long receiveTimeout)

Parameters:

receiveTimeout - the receiveTimeout

Returns:

the spec.

See Also:

• SimpleMessageListenerContainer.setReceiveTimeout(long)

batchSize

public SimpleMessageListenerContainerSpec batchSize(int batchSize)

The batch size to use.

Parameters:

batchSize - the batchSize.

Returns:

the spec.

Since:

5.2

See Also:

• SimpleMessageListenerContainer.setBatchSize(int)

consumerBatchEnabled

public SimpleMessageListenerContainerSpec consumerBatchEnabled(boolean enabled)

Set to true to enable batching of consumed messages.

Parameters:

enabled - true to enable.

Returns:

the spec.

Since:

5.3