public class DirectMessageListenerContainerSpec extends AbstractMessageListenerContainerSpec<DirectMessageListenerContainerSpec,DirectMessageListenerContainer>
DirectMessageListenerContainer.PARSER, targetloggerDEFAULT_PHASE| Constructor and Description |
|---|
DirectMessageListenerContainerSpec(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, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stopafterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingletonpublic DirectMessageListenerContainerSpec(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)