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
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)
Deprecated.
- this converter is not used by the container; it was only
used to configure the converter for a
@RabbitListener adapter.
That is now handled differently. If you are manually creating a listener
container, the converter must be configured in a listener adapter (if
present). |
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 |
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, 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)
@Deprecated public void setMessageConverter(MessageConverter messageConverter)
@RabbitListener
adapter.
That is now handled differently. If you are manually creating a listener
container, the converter must be configured in a listener adapter (if
present).MessageConverter
strategy for converting AMQP Messages.messageConverter
- the message converter to usepublic 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 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()
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