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 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
ConstructorDescriptionDirectMessageListenerContainerSpec
(DirectMessageListenerContainer listenerContainer) -
Method Summary
Modifier and TypeMethodDescriptionackTimeout
(long ackTimeout) consumersPerQueue
(int consumersPerQueue) 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
-
listenerContainer
-
-
Constructor Details
-
DirectMessageListenerContainerSpec
-
-
Method Details
-
consumersPerQueue
- Parameters:
consumersPerQueue
- the consumersPerQueue.- Returns:
- the spec.
- See Also:
-
messagesPerAck
- Parameters:
messagesPerAck
- the messages per ack.- Returns:
- the spec.
- See Also:
-
ackTimeout
- Parameters:
ackTimeout
- the ack timeout.- Returns:
- the spec.
- See Also:
-