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(Integer concurrency) |
void |
setConsecutiveActiveTrigger(Integer minConsecutiveActive) |
void |
setConsecutiveIdleTrigger(Integer minConsecutiveIdle) |
void |
setMaxConcurrentConsumers(Integer maxConcurrency) |
void |
setReceiveTimeout(Long receiveTimeout) |
void |
setStartConsumerMinInterval(Long minStartInterval) |
void |
setStopConsumerMinInterval(Long minStopInterval) |
void |
setTxSize(Integer txSize) |
createListenerContainer, getAdviceChain, setAcknowledgeMode, setAdviceChain, setAfterReceivePostProcessors, setApplicationContext, setApplicationEventPublisher, setAutoStartup, setChannelTransacted, setConnectionFactory, setConsumerTagStrategy, setDefaultRequeueRejected, setErrorHandler, setFailedDeclarationRetryInterval, setIdleEventInterval, setMessageConverter, setMismatchedQueuesFatal, setMissingQueuesFatal, setPhase, setPrefetchCount, setRecoveryBackOff, setRecoveryInterval, setTaskExecutor, setTransactionManagerpublic SimpleRabbitListenerContainerFactory()
public void setTxSize(Integer txSize)
txSize - the transaction size.SimpleMessageListenerContainer.setTxSize(int)public void setConcurrentConsumers(Integer concurrency)
concurrency - the minimum number of consumers to create.SimpleMessageListenerContainer.setConcurrentConsumers(int)public void setMaxConcurrentConsumers(Integer maxConcurrency)
maxConcurrency - the maximum number of consumers.SimpleMessageListenerContainer.setMaxConcurrentConsumers(int)public void setStartConsumerMinInterval(Long minStartInterval)
minStartInterval - The minimum interval between new consumer starts.SimpleMessageListenerContainer.setStartConsumerMinInterval(long)public void setStopConsumerMinInterval(Long minStopInterval)
minStopInterval - The minimum interval between consumer stops.SimpleMessageListenerContainer.setStopConsumerMinInterval(long)public void setConsecutiveActiveTrigger(Integer minConsecutiveActive)
minConsecutiveActive - The number of consecutive receives to trigger a new consumer.SimpleMessageListenerContainer.setConsecutiveActiveTrigger(int)public void setConsecutiveIdleTrigger(Integer minConsecutiveIdle)
minConsecutiveIdle - The number of consecutive timeouts to trigger stopping a consumer.SimpleMessageListenerContainer.setConsecutiveIdleTrigger(int)public void setReceiveTimeout(Long receiveTimeout)
receiveTimeout - the timeout.SimpleMessageListenerContainer.setReceiveTimeout(long)protected SimpleMessageListenerContainer createContainerInstance()
AbstractRabbitListenerContainerFactorycreateContainerInstance in class AbstractRabbitListenerContainerFactory<SimpleMessageListenerContainer>protected void initializeContainer(SimpleMessageListenerContainer instance, RabbitListenerEndpoint endpoint)
AbstractRabbitListenerContainerFactorySubclasses 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.