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
public 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)