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,org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer>
org.springframework.integration.amqp.dsl.DirectMessageListenerContainerSpec
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanClassLoaderAware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.FactoryBean<org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer>,org.springframework.beans.factory.InitializingBean,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle
public class DirectMessageListenerContainerSpec extends AbstractMessageListenerContainerSpec<DirectMessageListenerContainerSpec,org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer>
Spec for a
DirectMessageListenerContainer.- Since:
- 5.0
-
Field Summary
Fields Modifier and Type Field Description protected org.springframework.amqp.rabbit.listener.DirectMessageListenerContainerlistenerContainer -
Constructor Summary
Constructors Constructor Description DirectMessageListenerContainerSpec(org.springframework.amqp.rabbit.listener.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, stop
-
Field Details
-
listenerContainer
protected final org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer listenerContainer
-
-
Constructor Details
-
DirectMessageListenerContainerSpec
public DirectMessageListenerContainerSpec(org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer listenerContainer)
-
-
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)
-