public class SimpleMessageListenerContainerSpec extends AbstractMessageListenerContainerSpec<SimpleMessageListenerContainerSpec,org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer>
SimpleMessageListenerContainer.| Constructor and Description |
|---|
SimpleMessageListenerContainerSpec(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer) |
| Modifier and Type | Method and Description |
|---|---|
SimpleMessageListenerContainerSpec |
concurrentConsumers(int concurrentConsumers) |
SimpleMessageListenerContainerSpec |
consecutiveActiveTrigger(int consecutiveActiveTrigger) |
SimpleMessageListenerContainerSpec |
consecutiveIdleTrigger(int consecutiveIdleTrigger) |
SimpleMessageListenerContainerSpec |
maxConcurrentConsumers(int maxConcurrentConsumers) |
SimpleMessageListenerContainerSpec |
receiveTimeout(long receiveTimeout) |
SimpleMessageListenerContainerSpec |
startConsumerMinInterval(long startConsumerMinInterval) |
SimpleMessageListenerContainerSpec |
stopConsumerMinInterval(long stopConsumerMinInterval) |
SimpleMessageListenerContainerSpec |
txSize(int txSize) |
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, transactionManagerpublic SimpleMessageListenerContainerSpec(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer)
public SimpleMessageListenerContainerSpec concurrentConsumers(int concurrentConsumers)
concurrentConsumers - the concurrentConsumersSimpleMessageListenerContainer.setConcurrentConsumers(int)public SimpleMessageListenerContainerSpec maxConcurrentConsumers(int maxConcurrentConsumers)
maxConcurrentConsumers - the maxConcurrentConsumers.SimpleMessageListenerContainer.setMaxConcurrentConsumers(int)public SimpleMessageListenerContainerSpec startConsumerMinInterval(long startConsumerMinInterval)
startConsumerMinInterval - the startConsumerMinIntervalSimpleMessageListenerContainer.setStartConsumerMinInterval(long)public SimpleMessageListenerContainerSpec stopConsumerMinInterval(long stopConsumerMinInterval)
stopConsumerMinInterval - the stopConsumerMinInterval.SimpleMessageListenerContainer.setStopConsumerMinInterval(long)public SimpleMessageListenerContainerSpec consecutiveActiveTrigger(int consecutiveActiveTrigger)
consecutiveActiveTrigger - the consecutiveActiveTrigger.SimpleMessageListenerContainer.setConsecutiveActiveTrigger(int)public SimpleMessageListenerContainerSpec consecutiveIdleTrigger(int consecutiveIdleTrigger)
consecutiveIdleTrigger - the consecutiveIdleTrigger.SimpleMessageListenerContainer.setConsecutiveIdleTrigger(int)public SimpleMessageListenerContainerSpec receiveTimeout(long receiveTimeout)
receiveTimeout - the receiveTimeoutSimpleMessageListenerContainer.setReceiveTimeout(long)public SimpleMessageListenerContainerSpec txSize(int txSize)
txSize - the txSize.SimpleMessageListenerContainer.setTxSize(int)