AbstractRabbitListenerContainerFactory (Spring AMQP 2.0.11.RELEASE API)

java.lang.Object
- org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory<C>

Type Parameters:

C - the container type.

All Implemented Interfaces:

RabbitListenerContainerFactory<C>, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationEventPublisherAware

Direct Known Subclasses:

DirectRabbitListenerContainerFactory, SimpleRabbitListenerContainerFactory
```
public abstract class AbstractRabbitListenerContainerFactory<C extends AbstractMessageListenerContainer>
extends java.lang.Object
implements RabbitListenerContainerFactory<C>, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationEventPublisherAware
```
Base RabbitListenerContainerFactory for Spring's base container implementation.

Since:

1.4

Author:

Stephane Nicoll, Gary Russell, Artem Bilan, Joris Kuipers

See Also:

AbstractMessageListenerContainer

Field Summary

Fields
Modifier and Type Field and Description

protected java.util.concurrent.atomic.AtomicInteger counter

protected org.apache.commons.logging.Log logger

Fields
Modifier and Type	Field and Description
`protected java.util.concurrent.atomic.AtomicInteger`	`counter`
`protected org.apache.commons.logging.Log`	`logger`

Constructor Summary

Constructors
Constructor and Description

AbstractRabbitListenerContainerFactory()

Constructors
Constructor and Description
`AbstractRabbitListenerContainerFactory()`

Method Summary

All Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method and Description
`protected abstract C`	`createContainerInstance()` Create an empty container instance.
`C`	`createListenerContainer(RabbitListenerEndpoint endpoint)` Create a `MessageListenerContainer` for the given `RabbitListenerEndpoint`.
`org.aopalliance.aop.Advice[]`	`getAdviceChain()`
`protected void`	`initializeContainer(C instance, RabbitListenerEndpoint endpoint)` Further initialize the specified container.
`void`	`setAcknowledgeMode(AcknowledgeMode acknowledgeMode)`
`void`	`setAdviceChain(org.aopalliance.aop.Advice... adviceChain)`
`void`	`setAfterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors)` Set post processors which will be applied after the Message is received.
`void`	`setApplicationContext(org.springframework.context.ApplicationContext applicationContext)`
`void`	`setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)`
`void`	`setAutoStartup(java.lang.Boolean autoStartup)`
`void`	`setBeforeSendReplyPostProcessors(MessagePostProcessor... beforeSendReplyPostProcessors)` Set post processors that will be applied before sending replies; added to each message listener adapter.
`void`	`setChannelTransacted(java.lang.Boolean channelTransacted)`
`void`	`setConnectionFactory(ConnectionFactory connectionFactory)`
`void`	`setConsumerTagStrategy(ConsumerTagStrategy consumerTagStrategy)`
`void`	`setDefaultRequeueRejected(java.lang.Boolean requeueRejected)`
`void`	`setErrorHandler(org.springframework.util.ErrorHandler errorHandler)`
`void`	`setFailedDeclarationRetryInterval(java.lang.Long failedDeclarationRetryInterval)`
`void`	`setIdleEventInterval(java.lang.Long idleEventInterval)` How often to publish idle container events.
`void`	`setMessageConverter(MessageConverter messageConverter)`
`void`	`setMismatchedQueuesFatal(java.lang.Boolean mismatchedQueuesFatal)`
`void`	`setMissingQueuesFatal(java.lang.Boolean missingQueuesFatal)`
`void`	`setPhase(int phase)`
`void`	`setPrefetchCount(java.lang.Integer prefetch)`
`void`	`setRecoveryBackOff(org.springframework.util.backoff.BackOff recoveryBackOff)`
`void`	`setRecoveryInterval(java.lang.Long recoveryInterval)`
`void`	`setReplyRecoveryCallback(org.springframework.retry.RecoveryCallback<?> recoveryCallback)` Set a `RecoveryCallback` to invoke when retries are exhausted.
`void`	`setRetryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)` Set a `RetryTemplate` to use when sending replies; added to each message listener adapter.
`void`	`setTaskExecutor(java.util.concurrent.Executor taskExecutor)`
`void`	`setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - logger
```
protected final org.apache.commons.logging.Log logger
```
  - counter
```
protected final java.util.concurrent.atomic.AtomicInteger counter
```
- Constructor Detail
  - AbstractRabbitListenerContainerFactory
```
public AbstractRabbitListenerContainerFactory()
```
- Method Detail
  - setConnectionFactory
```
public void setConnectionFactory(ConnectionFactory connectionFactory)
```
    Parameters:
    
    connectionFactory - The connection factory.
    
    See Also:
    
    RabbitAccessor.setConnectionFactory(ConnectionFactory)
  - setErrorHandler
```
public void setErrorHandler(org.springframework.util.ErrorHandler errorHandler)
```
    Parameters:
    
    errorHandler - The error handler.
    
    See Also:
    
    AbstractMessageListenerContainer.setErrorHandler(org.springframework.util.ErrorHandler)
  - setMessageConverter
```
public void setMessageConverter(MessageConverter messageConverter)
```
    Parameters:
    
    messageConverter - the message converter to use
    
    See Also:
    
    AbstractMessageListenerContainer.setMessageConverter(MessageConverter)
  - setAcknowledgeMode
```
public void setAcknowledgeMode(AcknowledgeMode acknowledgeMode)
```
    Parameters:
    
    acknowledgeMode - the acknowledge mode to set. Defaults to AcknowledgeMode.AUTO
    
    See Also:
    
    AbstractMessageListenerContainer.setAcknowledgeMode(AcknowledgeMode)
  - setChannelTransacted
```
public void setChannelTransacted(java.lang.Boolean channelTransacted)
```
    Parameters:
    
    channelTransacted - the flag value to set
    
    See Also:
    
    RabbitAccessor.setChannelTransacted(boolean)
  - setTaskExecutor
```
public void setTaskExecutor(java.util.concurrent.Executor taskExecutor)
```
    Parameters:
    
    taskExecutor - the Executor to use.
    
    See Also:
    
    AbstractMessageListenerContainer.setTaskExecutor(java.util.concurrent.Executor)
  - setTransactionManager
```
public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
```
    Parameters:
    
    transactionManager - the PlatformTransactionManager to use.
    
    See Also:
    
    AbstractMessageListenerContainer.setTransactionManager(org.springframework.transaction.PlatformTransactionManager)
  - setPrefetchCount
```
public void setPrefetchCount(java.lang.Integer prefetch)
```
    Parameters:
    
    prefetch - the prefetch count
    
    See Also:
    
    AbstractMessageListenerContainer.setPrefetchCount(int)
  - setDefaultRequeueRejected
```
public void setDefaultRequeueRejected(java.lang.Boolean requeueRejected)
```
    Parameters:
    
    requeueRejected - true to reject by default.
    
    See Also:
    
    AbstractMessageListenerContainer.setDefaultRequeueRejected(boolean)
  - getAdviceChain
```
public org.aopalliance.aop.Advice[] getAdviceChain()
```
    Returns:
    
    the advice chain that was set. Defaults to null.
    
    Since:
    
    1.7.4
  - setAdviceChain
```
public void setAdviceChain(org.aopalliance.aop.Advice... adviceChain)
```
    Parameters:
    
    adviceChain - the advice chain to set.
    
    See Also:
    
    AbstractMessageListenerContainer.setAdviceChain(org.aopalliance.aop.Advice...)
  - setRecoveryInterval
```
public void setRecoveryInterval(java.lang.Long recoveryInterval)
```
    Parameters:
    
    recoveryInterval - The recovery interval.
    
    See Also:
    
    AbstractMessageListenerContainer.setRecoveryInterval(long)
  - setRecoveryBackOff
```
public void setRecoveryBackOff(org.springframework.util.backoff.BackOff recoveryBackOff)
```
    Parameters:
    
    recoveryBackOff - The BackOff to recover.
    
    Since:
    
    1.5
    
    See Also:
    
    AbstractMessageListenerContainer.setRecoveryBackOff(BackOff)
  - setMissingQueuesFatal
```
public void setMissingQueuesFatal(java.lang.Boolean missingQueuesFatal)
```
    Parameters:
    
    missingQueuesFatal - the missingQueuesFatal to set.
    
    See Also:
    
    SimpleMessageListenerContainer.setMissingQueuesFatal(boolean)
  - setMismatchedQueuesFatal
```
public void setMismatchedQueuesFatal(java.lang.Boolean mismatchedQueuesFatal)
```
    Parameters:
    
    mismatchedQueuesFatal - the mismatchedQueuesFatal to set.
    
    Since:
    
    1.6
    
    See Also:
    
    AbstractMessageListenerContainer.setMismatchedQueuesFatal(boolean)
  - setConsumerTagStrategy
```
public void setConsumerTagStrategy(ConsumerTagStrategy consumerTagStrategy)
```
    Parameters:
    
    consumerTagStrategy - the consumerTagStrategy to set
    
    See Also:
    
    AbstractMessageListenerContainer.setConsumerTagStrategy(ConsumerTagStrategy)
  - setIdleEventInterval
```
public void setIdleEventInterval(java.lang.Long idleEventInterval)
```
    How often to publish idle container events.
    
    Parameters:
    
    idleEventInterval - the interval.
  - setFailedDeclarationRetryInterval
```
public void setFailedDeclarationRetryInterval(java.lang.Long failedDeclarationRetryInterval)
```
  - setApplicationEventPublisher
```
public void setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)
```
    Specified by:
    
    setApplicationEventPublisher in interface org.springframework.context.ApplicationEventPublisherAware
  - setApplicationContext
```
public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
                           throws org.springframework.beans.BeansException
```
    Specified by:
    
    setApplicationContext in interface org.springframework.context.ApplicationContextAware
    
    Throws:
    
    org.springframework.beans.BeansException
  - setAutoStartup
```
public void setAutoStartup(java.lang.Boolean autoStartup)
```
    Parameters:
    
    autoStartup - true for auto startup.
    
    See Also:
    
    AbstractMessageListenerContainer.setAutoStartup(boolean)
  - setPhase
```
public void setPhase(int phase)
```
    Parameters:
    
    phase - The phase.
    
    See Also:
    
    AbstractMessageListenerContainer.setPhase(int)
  - setAfterReceivePostProcessors
```
public void setAfterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors)
```
    Set post processors which will be applied after the Message is received.
    
    Parameters:
    
    afterReceivePostProcessors - the post processors.
    
    Since:
    
    2.0
    
    See Also:
    
    AbstractMessageListenerContainer.setAfterReceivePostProcessors(MessagePostProcessor...)
  - setBeforeSendReplyPostProcessors
```
public void setBeforeSendReplyPostProcessors(MessagePostProcessor... beforeSendReplyPostProcessors)
```
    Set post processors that will be applied before sending replies; added to each message listener adapter.
    
    Parameters:
    
    beforeSendReplyPostProcessors - the post processors.
    
    Since:
    
    2.0.3
    
    See Also:
    
    AbstractAdaptableMessageListener.setBeforeSendReplyPostProcessors(MessagePostProcessor...)
  - setRetryTemplate
```
public void setRetryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)
```
    Set a RetryTemplate to use when sending replies; added to each message listener adapter.
    
    Parameters:
    
    retryTemplate - the template.
    
    Since:
    
    2.0.6
    
    See Also:
    
    setReplyRecoveryCallback(RecoveryCallback), AbstractAdaptableMessageListener.setRetryTemplate(RetryTemplate)
  - setReplyRecoveryCallback
```
public void setReplyRecoveryCallback(org.springframework.retry.RecoveryCallback<?> recoveryCallback)
```
    Set a RecoveryCallback to invoke when retries are exhausted. Added to each message listener adapter. Only used if a retryTemplate is provided.
    
    Parameters:
    
    recoveryCallback - the recovery callback.
    
    Since:
    
    2.0.6
    
    See Also:
    
    setRetryTemplate(RetryTemplate), AbstractAdaptableMessageListener.setRecoveryCallback(RecoveryCallback)
  - createListenerContainer
```
public C createListenerContainer(RabbitListenerEndpoint endpoint)
```
    Description copied from interface: RabbitListenerContainerFactory
    
    Create a MessageListenerContainer for the given RabbitListenerEndpoint.
    
    Specified by:
    
    createListenerContainer in interface RabbitListenerContainerFactory<C extends AbstractMessageListenerContainer>
    
    Parameters:
    
    endpoint - the endpoint to configure
    
    Returns:
    
    the created container
  - createContainerInstance
```
protected abstract C createContainerInstance()
```
    Create an empty container instance.
    
    Returns:
    
    the new container instance.
  - initializeContainer
```
protected void initializeContainer(C instance,
                                   RabbitListenerEndpoint endpoint)
```
    Further initialize the specified container.
    Subclasses can inherit from this method to apply extra configuration if necessary.
    
    Parameters:
    
    instance - the container instance to configure.
    
    endpoint - the endpoint.

Class AbstractRabbitListenerContainerFactory<C extends AbstractMessageListenerContainer>

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

logger

counter

Constructor Detail

AbstractRabbitListenerContainerFactory

Method Detail

setConnectionFactory

setErrorHandler

setMessageConverter

setAcknowledgeMode

setChannelTransacted

setTaskExecutor

setTransactionManager

setPrefetchCount

setDefaultRequeueRejected

getAdviceChain

setAdviceChain

setRecoveryInterval

setRecoveryBackOff

setMissingQueuesFatal

setMismatchedQueuesFatal

setConsumerTagStrategy

setIdleEventInterval

setFailedDeclarationRetryInterval

setApplicationEventPublisher

setApplicationContext

setAutoStartup

setPhase

setAfterReceivePostProcessors

setBeforeSendReplyPostProcessors

setRetryTemplate

setReplyRecoveryCallback

createListenerContainer

createContainerInstance

initializeContainer