public class SimpleRabbitListenerContainerFactory extends AbstractRabbitListenerContainerFactory<SimpleMessageListenerContainer>
RabbitListenerContainerFactory
implementation to build a regular
SimpleMessageListenerContainer
.
This should be the default for most users and a good transition paths for those that are used to build such container definition manually.
counter, logger
Constructor and Description |
---|
SimpleRabbitListenerContainerFactory() |
Modifier and Type | Method and Description |
---|---|
protected SimpleMessageListenerContainer |
createContainerInstance()
Create an empty container instance.
|
protected void |
initializeContainer(SimpleMessageListenerContainer instance,
RabbitListenerEndpoint endpoint)
Further initialize the specified container.
|
void |
setConcurrentConsumers(java.lang.Integer concurrency) |
void |
setConsecutiveActiveTrigger(java.lang.Integer minConsecutiveActive) |
void |
setConsecutiveIdleTrigger(java.lang.Integer minConsecutiveIdle) |
void |
setDeBatchingEnabled(java.lang.Boolean deBatchingEnabled)
Determine whether or not the container should de-batch batched
messages (true) or call the listener with the batch (false).
|
void |
setMaxConcurrentConsumers(java.lang.Integer maxConcurrency) |
void |
setReceiveTimeout(java.lang.Long receiveTimeout) |
void |
setStartConsumerMinInterval(java.lang.Long minStartInterval) |
void |
setStopConsumerMinInterval(java.lang.Long minStopInterval) |
void |
setTxSize(java.lang.Integer txSize) |
createListenerContainer, getAdviceChain, setAcknowledgeMode, setAdviceChain, setAfterReceivePostProcessors, setApplicationContext, setApplicationEventPublisher, setAutoStartup, setBeforeSendReplyPostProcessors, setChannelTransacted, setConnectionFactory, setConsumerTagStrategy, setDefaultRequeueRejected, setErrorHandler, setFailedDeclarationRetryInterval, setIdleEventInterval, setMessageConverter, setMismatchedQueuesFatal, setMissingQueuesFatal, setPhase, setPrefetchCount, setRecoveryBackOff, setRecoveryInterval, setReplyRecoveryCallback, setRetryTemplate, setTaskExecutor, setTransactionManager
public SimpleRabbitListenerContainerFactory()
public void setTxSize(java.lang.Integer txSize)
txSize
- the transaction size.SimpleMessageListenerContainer.setTxSize(int)
public void setConcurrentConsumers(java.lang.Integer concurrency)
concurrency
- the minimum number of consumers to create.SimpleMessageListenerContainer.setConcurrentConsumers(int)
public void setMaxConcurrentConsumers(java.lang.Integer maxConcurrency)
maxConcurrency
- the maximum number of consumers.SimpleMessageListenerContainer.setMaxConcurrentConsumers(int)
public void setStartConsumerMinInterval(java.lang.Long minStartInterval)
minStartInterval
- The minimum interval between new consumer starts.SimpleMessageListenerContainer.setStartConsumerMinInterval(long)
public void setStopConsumerMinInterval(java.lang.Long minStopInterval)
minStopInterval
- The minimum interval between consumer stops.SimpleMessageListenerContainer.setStopConsumerMinInterval(long)
public void setConsecutiveActiveTrigger(java.lang.Integer minConsecutiveActive)
minConsecutiveActive
- The number of consecutive receives to trigger a new consumer.SimpleMessageListenerContainer.setConsecutiveActiveTrigger(int)
public void setConsecutiveIdleTrigger(java.lang.Integer minConsecutiveIdle)
minConsecutiveIdle
- The number of consecutive timeouts to trigger stopping a consumer.SimpleMessageListenerContainer.setConsecutiveIdleTrigger(int)
public void setReceiveTimeout(java.lang.Long receiveTimeout)
receiveTimeout
- the timeout.SimpleMessageListenerContainer.setReceiveTimeout(long)
public void setDeBatchingEnabled(java.lang.Boolean deBatchingEnabled)
deBatchingEnabled
- whether or not to disable de-batching of messages.AbstractMessageListenerContainer.setDeBatchingEnabled(boolean)
protected SimpleMessageListenerContainer createContainerInstance()
AbstractRabbitListenerContainerFactory
createContainerInstance
in class AbstractRabbitListenerContainerFactory<SimpleMessageListenerContainer>
protected void initializeContainer(SimpleMessageListenerContainer instance, RabbitListenerEndpoint endpoint)
AbstractRabbitListenerContainerFactory
Subclasses can inherit from this method to apply extra configuration if necessary.
initializeContainer
in class AbstractRabbitListenerContainerFactory<SimpleMessageListenerContainer>
instance
- the container instance to configure.endpoint
- the endpoint.