public class SimpleMessageListenerContainerSpec extends AbstractMessageListenerContainerSpec<SimpleMessageListenerContainerSpec,org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer>
SimpleMessageListenerContainer.| Modifier and Type | Field and Description |
|---|---|
protected org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer |
listenerContainer |
| Constructor and Description |
|---|
SimpleMessageListenerContainerSpec(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer) |
| Modifier and Type | Method and Description |
|---|---|
SimpleMessageListenerContainerSpec |
batchSize(int batchSize)
The batch size to use.
|
SimpleMessageListenerContainerSpec |
concurrentConsumers(int concurrentConsumers) |
SimpleMessageListenerContainerSpec |
consecutiveActiveTrigger(int consecutiveActiveTrigger) |
SimpleMessageListenerContainerSpec |
consecutiveIdleTrigger(int consecutiveIdleTrigger) |
SimpleMessageListenerContainerSpec |
consumerBatchEnabled(boolean enabled)
Set to true to enable batching of consumed messages.
|
SimpleMessageListenerContainerSpec |
maxConcurrentConsumers(int maxConcurrentConsumers) |
SimpleMessageListenerContainerSpec |
receiveTimeout(long receiveTimeout) |
SimpleMessageListenerContainerSpec |
startConsumerMinInterval(long startConsumerMinInterval) |
SimpleMessageListenerContainerSpec |
stopConsumerMinInterval(long stopConsumerMinInterval) |
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, stopprotected final org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer
public 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 batchSize(int batchSize)
batchSize - the batchSize.SimpleMessageListenerContainer.setBatchSize(int)public SimpleMessageListenerContainerSpec consumerBatchEnabled(boolean enabled)
enabled - true to enable.