public class SimpleMessageListenerContainerSpec extends AbstractMessageListenerContainerSpec<SimpleMessageListenerContainerSpec,SimpleMessageListenerContainer>
SimpleMessageListenerContainer
.PARSER, target
logger
DEFAULT_PHASE
OBJECT_TYPE_ATTRIBUTE
Constructor and Description |
---|
SimpleMessageListenerContainerSpec(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 |
maxConcurrentConsumers(int maxConcurrentConsumers) |
SimpleMessageListenerContainerSpec |
receiveTimeout(long receiveTimeout) |
SimpleMessageListenerContainerSpec |
startConsumerMinInterval(long startConsumerMinInterval) |
SimpleMessageListenerContainerSpec |
stopConsumerMinInterval(long stopConsumerMinInterval) |
SimpleMessageListenerContainerSpec |
txSize(int txSize)
Deprecated.
since 5.2 in favor of
batchSize(int) |
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
public SimpleMessageListenerContainerSpec(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)
@Deprecated public SimpleMessageListenerContainerSpec txSize(int txSize)
batchSize(int)
txSize
- the txSize.SimpleMessageListenerContainer.setBatchSize(int)
public SimpleMessageListenerContainerSpec batchSize(int batchSize)
batchSize
- the batchSize.SimpleMessageListenerContainer.setBatchSize(int)