Class DirectMessageListenerContainerSpec
java.lang.Object
org.springframework.beans.factory.config.AbstractFactoryBean<T>
org.springframework.integration.dsl.IntegrationComponentSpec<S,C>
org.springframework.integration.amqp.dsl.MessageListenerContainerSpec<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
FieldsFields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
PARSER, targetFields inherited from class org.springframework.beans.factory.config.AbstractFactoryBean
loggerFields inherited from interface org.springframework.beans.factory.FactoryBean
OBJECT_TYPE_ATTRIBUTEFields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE -
Constructor Summary
ConstructorsConstructorDescriptionDirectMessageListenerContainerSpec(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, transactionManagerMethods inherited from class org.springframework.integration.amqp.dsl.MessageListenerContainerSpec
queueNameMethods 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
-
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:
-