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 DirectMessageListenerContainer
listenerContainer
Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
PARSER, target
-
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
-
Field Details
-
Constructor Details
-
Method Details
-
consumersPerQueue
- Parameters:
consumersPerQueue
- the consumersPerQueue.- Returns:
- the spec.
- See Also:
DirectMessageListenerContainer.setConsumersPerQueue(int)
-
messagesPerAck
- Parameters:
messagesPerAck
- the messages per ack.- Returns:
- the spec.
- See Also:
DirectMessageListenerContainer.setMessagesPerAck(int)
-
ackTimeout
- Parameters:
ackTimeout
- the ack timeout.- Returns:
- the spec.
- See Also:
DirectMessageListenerContainer.setAckTimeout(long)
-