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 DirectMessageListenerContainerlistenerContainerFields 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 DirectMessageListenerContainerSpecackTimeout(long ackTimeout)DirectMessageListenerContainerSpecconsumersPerQueue(int consumersPerQueue)DirectMessageListenerContainerSpecmessagesPerAck(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, transactionManagerMethods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stopMethods 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)
-