public class ListenerContainerFactoryBean extends AbstractFactoryBean<AbstractMessageListenerContainer> implements ApplicationContextAware, BeanNameAware, ApplicationEventPublisherAware, SmartLifecycle
Modifier and Type | Class and Description |
---|---|
static class |
ListenerContainerFactoryBean.Type
The container type.
|
logger
DEFAULT_PHASE
OBJECT_TYPE_ATTRIBUTE
Constructor and Description |
---|
ListenerContainerFactoryBean() |
Modifier and Type | Method and Description |
---|---|
protected AbstractMessageListenerContainer |
createInstance() |
Class<?> |
getObjectType() |
int |
getPhase() |
boolean |
isAutoStartup() |
boolean |
isRunning() |
void |
setAcknowledgeMode(AcknowledgeMode acknowledgeMode) |
void |
setAdviceChain(Advice... adviceChain) |
void |
setAfterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors) |
void |
setApplicationContext(ApplicationContext applicationContext) |
void |
setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) |
void |
setAutoDeclare(boolean autoDeclare) |
void |
setAutoStartup(boolean autoStartup) |
void |
setBatchSize(int batchSize)
This property has several functions.
|
void |
setBeanName(String beanName) |
void |
setChannelTransacted(boolean transactional) |
void |
setConcurrentConsumers(int concurrentConsumers) |
void |
setConnectionFactory(ConnectionFactory connectionFactory) |
void |
setConsecutiveActiveTrigger(int consecutiveActiveTrigger) |
void |
setConsecutiveIdleTrigger(int consecutiveIdleTrigger) |
void |
setConsumerArguments(Map<String,Object> args) |
void |
setConsumerBatchEnabled(boolean consumerBatchEnabled)
Set to true to present a list of messages based on the
setBatchSize(int) ,
if the container and listener support it. |
void |
setConsumersPerQueue(int consumersPerQueue) |
void |
setConsumerTagStrategy(ConsumerTagStrategy consumerTagStrategy) |
void |
setDeBatchingEnabled(boolean deBatchingEnabled) |
void |
setDeclarationRetries(int declarationRetries) |
void |
setDefaultRequeueRejected(boolean defaultRequeueRejected) |
void |
setErrorHandler(ErrorHandler errorHandler) |
void |
setExclusive(boolean exclusive) |
void |
setExclusiveConsumerExceptionLogger(ConditionalExceptionLogger exclusiveConsumerExceptionLogger) |
void |
setExposeListenerChannel(boolean exposeListenerChannel) |
void |
setFailedDeclarationRetryInterval(long failedDeclarationRetryInterval) |
void |
setIdleEventInterval(long idleEventInterval) |
void |
setListenerId(String listenerId) |
void |
setMaxConcurrentConsumers(int maxConcurrentConsumers) |
void |
setMessageListener(MessageListener messageListener) |
void |
setMessagePropertiesConverter(MessagePropertiesConverter messagePropertiesConverter) |
void |
setMismatchedQueuesFatal(boolean mismatchedQueuesFatal) |
void |
setMissingQueuesFatal(boolean missingQueuesFatal) |
void |
setMonitorInterval(long monitorInterval) |
void |
setNoLocal(Boolean noLocal) |
void |
setPhase(int phase) |
void |
setPossibleAuthenticationFailureFatal(Boolean possibleAuthenticationFailureFatal) |
void |
setPrefetchCount(int prefetchCount) |
void |
setQueueNames(String... queueName) |
void |
setQueues(Queue... queues) |
void |
setRabbitAdmin(RabbitAdmin rabbitAdmin) |
void |
setReceiveTimeout(long receiveTimeout) |
void |
setRecoveryBackOff(BackOff recoveryBackOff) |
void |
setRecoveryInterval(long recoveryInterval) |
void |
setRetryDeclarationInterval(long retryDeclarationInterval) |
void |
setShutdownTimeout(long shutdownTimeout) |
void |
setStartConsumerMinInterval(long startConsumerMinInterval) |
void |
setStopConsumerMinInterval(long stopConsumerMinInterval) |
void |
setTaskExecutor(Executor taskExecutor) |
void |
setTaskScheduler(TaskScheduler taskScheduler) |
void |
setTransactionAttribute(TransactionAttribute transactionAttribute) |
void |
setTransactionManager(PlatformTransactionManager transactionManager) |
void |
setType(ListenerContainerFactoryBean.Type type) |
void |
start() |
void |
stop() |
void |
stop(Runnable callback) |
afterPropertiesSet, destroy, destroyInstance, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
setApplicationEventPublisher
in interface ApplicationEventPublisherAware
public void setBeanName(String beanName)
setBeanName
in interface BeanNameAware
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
setApplicationContext
in interface ApplicationContextAware
BeansException
public void setType(ListenerContainerFactoryBean.Type type)
public void setConnectionFactory(ConnectionFactory connectionFactory)
public void setChannelTransacted(boolean transactional)
public void setAcknowledgeMode(AcknowledgeMode acknowledgeMode)
public void setQueueNames(String... queueName)
public void setQueues(Queue... queues)
public void setExposeListenerChannel(boolean exposeListenerChannel)
public void setMessageListener(MessageListener messageListener)
public void setErrorHandler(ErrorHandler errorHandler)
public void setDeBatchingEnabled(boolean deBatchingEnabled)
public void setAdviceChain(Advice... adviceChain)
public void setAfterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors)
public void setAutoStartup(boolean autoStartup)
public void setPhase(int phase)
public void setListenerId(String listenerId)
public void setConsumerTagStrategy(ConsumerTagStrategy consumerTagStrategy)
public void setNoLocal(Boolean noLocal)
public void setExclusive(boolean exclusive)
public void setDefaultRequeueRejected(boolean defaultRequeueRejected)
public void setPrefetchCount(int prefetchCount)
public void setShutdownTimeout(long shutdownTimeout)
public void setIdleEventInterval(long idleEventInterval)
public void setTransactionManager(PlatformTransactionManager transactionManager)
public void setTransactionAttribute(TransactionAttribute transactionAttribute)
public void setTaskExecutor(Executor taskExecutor)
public void setRecoveryInterval(long recoveryInterval)
public void setRecoveryBackOff(BackOff recoveryBackOff)
public void setMessagePropertiesConverter(MessagePropertiesConverter messagePropertiesConverter)
public void setRabbitAdmin(RabbitAdmin rabbitAdmin)
public void setMissingQueuesFatal(boolean missingQueuesFatal)
public void setPossibleAuthenticationFailureFatal(Boolean possibleAuthenticationFailureFatal)
public void setMismatchedQueuesFatal(boolean mismatchedQueuesFatal)
public void setAutoDeclare(boolean autoDeclare)
public void setFailedDeclarationRetryInterval(long failedDeclarationRetryInterval)
public void setExclusiveConsumerExceptionLogger(ConditionalExceptionLogger exclusiveConsumerExceptionLogger)
public void setConsumersPerQueue(int consumersPerQueue)
public void setTaskScheduler(TaskScheduler taskScheduler)
public void setMonitorInterval(long monitorInterval)
public void setConcurrentConsumers(int concurrentConsumers)
public void setMaxConcurrentConsumers(int maxConcurrentConsumers)
public void setStartConsumerMinInterval(long startConsumerMinInterval)
public void setStopConsumerMinInterval(long stopConsumerMinInterval)
public void setConsecutiveActiveTrigger(int consecutiveActiveTrigger)
public void setConsecutiveIdleTrigger(int consecutiveIdleTrigger)
public void setReceiveTimeout(long receiveTimeout)
public void setBatchSize(int batchSize)
When the channel is transacted, it determines how many messages to process in a
single transaction. It should be less than or equal to
the prefetch count
.
It also affects how often acks are sent when using
AcknowledgeMode.AUTO
- one ack per BatchSize.
Finally, when setConsumerBatchEnabled(boolean)
is true, it determines how
many records to include in the batch as long as sufficient messages arrive within
setReceiveTimeout(long)
.
IMPORTANT The batch size represents the number of physical messages
received. If setDeBatchingEnabled(boolean)
is true and a message is a
batch created by a producer, the actual number of messages received by the listener
will be larger than this batch size.
Default is 1.
batchSize
- the batch sizepublic void setConsumerBatchEnabled(boolean consumerBatchEnabled)
setBatchSize(int)
,
if the container and listener support it.consumerBatchEnabled
- true to create message batches in the container.setBatchSize(int)
public void setDeclarationRetries(int declarationRetries)
public void setRetryDeclarationInterval(long retryDeclarationInterval)
public Class<?> getObjectType()
getObjectType
in interface FactoryBean<AbstractMessageListenerContainer>
getObjectType
in class AbstractFactoryBean<AbstractMessageListenerContainer>
protected AbstractMessageListenerContainer createInstance()
createInstance
in class AbstractFactoryBean<AbstractMessageListenerContainer>
public int getPhase()
getPhase
in interface Phased
getPhase
in interface SmartLifecycle
public boolean isAutoStartup()
isAutoStartup
in interface SmartLifecycle
public void stop(Runnable callback)
stop
in interface SmartLifecycle