Package org.springframework.integration.amqp.dsl

Class DirectMessageListenerContainerSpec

java.lang.Object

org.springframework.beans.factory.config.AbstractFactoryBean<T>

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

org.springframework.integration.amqp.dsl.AbstractMessageListenerContainerSpec<DirectMessageListenerContainerSpec,DirectMessageListenerContainer>

org.springframework.integration.amqp.dsl.DirectMessageListenerContainerSpec

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, DisposableBean, FactoryBean<DirectMessageListenerContainer>, InitializingBean, Lifecycle, Phased, SmartLifecycle

public class DirectMessageListenerContainerSpec
extends AbstractMessageListenerContainerSpec<DirectMessageListenerContainerSpec,DirectMessageListenerContainer>

Spec for a DirectMessageListenerContainer.

Since:

5.0

Author:

Gary Russell

Field Summary

Fields

Modifier and Type	Field	Description
protected final DirectMessageListenerContainer	listenerContainer

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

Constructor	Description
DirectMessageListenerContainerSpec(DirectMessageListenerContainer listenerContainer)

Method Summary

Modifier and Type	Method	Description
DirectMessageListenerContainerSpec	ackTimeout(long ackTimeout)
DirectMessageListenerContainerSpec	consumersPerQueue(int consumersPerQueue)
DirectMessageListenerContainerSpec	messagesPerAck(int messagesPerAck)

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.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

Field Details

listenerContainer

protected final DirectMessageListenerContainer listenerContainer

Constructor Details

DirectMessageListenerContainerSpec

public DirectMessageListenerContainerSpec(DirectMessageListenerContainer listenerContainer)

Method Details

consumersPerQueue

public DirectMessageListenerContainerSpec consumersPerQueue(int consumersPerQueue)

Parameters:

consumersPerQueue - the consumersPerQueue.

Returns:

the spec.

See Also:

• DirectMessageListenerContainer.setConsumersPerQueue(int)

messagesPerAck

public DirectMessageListenerContainerSpec messagesPerAck(int messagesPerAck)

Parameters:

messagesPerAck - the messages per ack.

Returns:

the spec.

See Also:

• DirectMessageListenerContainer.setMessagesPerAck(int)

ackTimeout

public DirectMessageListenerContainerSpec ackTimeout(long ackTimeout)

Parameters:

ackTimeout - the ack timeout.

Returns:

the spec.

See Also:

• DirectMessageListenerContainer.setAckTimeout(long)