public class ListenerContainerFactoryBean extends org.springframework.beans.factory.config.AbstractFactoryBean<AbstractMessageListenerContainer> implements org.springframework.context.ApplicationContextAware, org.springframework.beans.factory.BeanNameAware, org.springframework.context.ApplicationEventPublisherAware, org.springframework.context.SmartLifecycle
Modifier and Type | Class and Description |
---|---|
static class |
ListenerContainerFactoryBean.Type
The container type.
|
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(org.aopalliance.aop.Advice... adviceChain) |
void |
setAfterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors) |
void |
setApplicationContext(org.springframework.context.ApplicationContext applicationContext) |
void |
setApplicationEventPublisher(org.springframework.context.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(org.springframework.util.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 |
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(org.springframework.util.backoff.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(org.springframework.scheduling.TaskScheduler taskScheduler) |
void |
setTransactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute) |
void |
setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) |
void |
setTxSize(int txSize) |
void |
setType(ListenerContainerFactoryBean.Type type) |
void |
start() |
void |
stop() |
void |
stop(Runnable callback) |
public void setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)
setApplicationEventPublisher
in interface org.springframework.context.ApplicationEventPublisherAware
public void setBeanName(String beanName)
setBeanName
in interface org.springframework.beans.factory.BeanNameAware
public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext) throws org.springframework.beans.BeansException
setApplicationContext
in interface org.springframework.context.ApplicationContextAware
org.springframework.beans.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(Object messageListener)
public void setErrorHandler(org.springframework.util.ErrorHandler errorHandler)
public void setMessageConverter(MessageConverter messageConverter)
public void setDeBatchingEnabled(boolean deBatchingEnabled)
public void setAdviceChain(org.aopalliance.aop.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(org.springframework.transaction.PlatformTransactionManager transactionManager)
public void setTransactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute)
public void setTaskExecutor(Executor taskExecutor)
public void setRecoveryInterval(long recoveryInterval)
public void setRecoveryBackOff(org.springframework.util.backoff.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(org.springframework.scheduling.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 org.springframework.beans.factory.FactoryBean<AbstractMessageListenerContainer>
getObjectType
in class org.springframework.beans.factory.config.AbstractFactoryBean<AbstractMessageListenerContainer>
protected AbstractMessageListenerContainer createInstance() throws Exception
createInstance
in class org.springframework.beans.factory.config.AbstractFactoryBean<AbstractMessageListenerContainer>
Exception
public void start()
start
in interface org.springframework.context.Lifecycle
public void stop()
stop
in interface org.springframework.context.Lifecycle
public boolean isRunning()
isRunning
in interface org.springframework.context.Lifecycle
public int getPhase()
getPhase
in interface org.springframework.context.Phased
public boolean isAutoStartup()
isAutoStartup
in interface org.springframework.context.SmartLifecycle
public void stop(Runnable callback)
stop
in interface org.springframework.context.SmartLifecycle