public class DirectMessageListenerContainerSpec extends AbstractMessageListenerContainerSpec<DirectMessageListenerContainerSpec,DirectMessageListenerContainer>
DirectMessageListenerContainer
.Modifier and Type | Field and Description |
---|---|
protected DirectMessageListenerContainer |
listenerContainer |
PARSER, target
logger
DEFAULT_PHASE
OBJECT_TYPE_ATTRIBUTE
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, stop
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
protected final DirectMessageListenerContainer listenerContainer
public 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)