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| 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 |
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 |
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 |
setMessageConverter(MessageConverter messageConverter) |
void |
setMessageListener(Object messageListener) |
void |
setMessagePropertiesConverter(MessagePropertiesConverter messagePropertiesConverter) |
void |
setMismatchedQueuesFatal(boolean mismatchedQueuesFatal) |
void |
setMissingQueuesFatal(boolean missingQueuesFatal) |
void |
setMonitorInterval(long monitorInterval) |
void |
setPhase(int phase) |
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 |
setTxSize(int txSize) |
void |
setType(ListenerContainerFactoryBean.Type type) |
void |
start() |
void |
stop() |
void |
stop(Runnable callback) |
afterPropertiesSet, destroy, destroyInstance, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingletonpublic void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
setApplicationEventPublisher in interface ApplicationEventPublisherAwarepublic void setBeanName(String beanName)
setBeanName in interface BeanNameAwarepublic void setApplicationContext(ApplicationContext applicationContext) throws BeansException
setApplicationContext in interface ApplicationContextAwareBeansExceptionpublic 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(Object messageListener)
public void setErrorHandler(ErrorHandler errorHandler)
public void setMessageConverter(MessageConverter messageConverter)
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 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 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 setTxSize(int txSize)
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() throws Exception
createInstance in class AbstractFactoryBean<AbstractMessageListenerContainer>Exceptionpublic boolean isAutoStartup()
isAutoStartup in interface SmartLifecyclepublic void stop(Runnable callback)
stop in interface SmartLifecycle