public class DirectMessageListenerContainerSpec extends AbstractMessageListenerContainerSpec<DirectMessageListenerContainerSpec,org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer>
DirectMessageListenerContainer.logger, PARSER, target| Constructor and Description |
|---|
DirectMessageListenerContainerSpec(org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer listenerContainer) |
| Modifier and Type | Method and Description |
|---|---|
DirectMessageListenerContainerSpec |
ackTimeout(long ackTimeout) |
DirectMessageListenerContainerSpec |
consumersPerQueue(int consumersPerQueue) |
DirectMessageListenerContainerSpec |
messagesPerAck(int messagesPerAck) |
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_this, afterPropertiesSet, destroy, doGet, get, getId, getObject, getObjectType, isSingletonpublic DirectMessageListenerContainerSpec(org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer listenerContainer)
public DirectMessageListenerContainerSpec consumersPerQueue(int consumersPerQueue)
consumersPerQueue - the consumersPerQueue.DirectMessageListenerContainer.setConsumersPerQueue(int)public DirectMessageListenerContainerSpec messagesPerAck(int messagesPerAck)
messagesPerAck - the messages per ack.DirectMessageListenerContainer.setMessagesPerAck(int)public DirectMessageListenerContainerSpec ackTimeout(long ackTimeout)
ackTimeout - the ack timeout.DirectMessageListenerContainer.setAckTimeout(long)