public abstract class AbstractRabbitListenerContainerFactory<C extends AbstractMessageListenerContainer> extends java.lang.Object implements RabbitListenerContainerFactory<C>
RabbitListenerContainerFactory for Spring's base container implementation.AbstractMessageListenerContainer| Modifier and Type | Field and Description |
|---|---|
protected java.util.concurrent.atomic.AtomicInteger |
counter |
protected org.apache.commons.logging.Log |
logger |
| Constructor and Description |
|---|
AbstractRabbitListenerContainerFactory() |
| 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. |
protected void |
initializeContainer(C instance)
Further initialize the specified container.
|
void |
setAcknowledgeMode(org.springframework.amqp.core.AcknowledgeMode acknowledgeMode) |
void |
setAutoStartup(java.lang.Boolean autoStartup) |
void |
setChannelTransacted(java.lang.Boolean channelTransacted) |
void |
setConnectionFactory(ConnectionFactory connectionFactory) |
void |
setErrorHandler(org.springframework.util.ErrorHandler errorHandler) |
void |
setMessageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter) |
void |
setPhase(int phase) |
protected final org.apache.commons.logging.Log logger
protected final java.util.concurrent.atomic.AtomicInteger counter
public AbstractRabbitListenerContainerFactory()
public void setConnectionFactory(ConnectionFactory connectionFactory)
connectionFactory - The connection factory.RabbitAccessor.setConnectionFactory(ConnectionFactory)public void setErrorHandler(org.springframework.util.ErrorHandler errorHandler)
errorHandler - The error handler.AbstractMessageListenerContainer.setErrorHandler(org.springframework.util.ErrorHandler)public void setMessageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)
messageConverter - the message converter to useAbstractMessageListenerContainer.setMessageConverter(MessageConverter)public void setAcknowledgeMode(org.springframework.amqp.core.AcknowledgeMode acknowledgeMode)
acknowledgeMode - the acknowledge mode to set. Defaults to AcknowledgeMode.AUTOAbstractMessageListenerContainer.setAcknowledgeMode(AcknowledgeMode)public void setChannelTransacted(java.lang.Boolean channelTransacted)
channelTransacted - the flag value to setRabbitAccessor.setChannelTransacted(boolean)public void setAutoStartup(java.lang.Boolean autoStartup)
autoStartup - true for auto startup.AbstractMessageListenerContainer.setAutoStartup(boolean)public void setPhase(int phase)
phase - The phase.AbstractMessageListenerContainer.setPhase(int)public C createListenerContainer(RabbitListenerEndpoint endpoint)
RabbitListenerContainerFactoryMessageListenerContainer for the given RabbitListenerEndpoint.createListenerContainer in interface RabbitListenerContainerFactory<C extends AbstractMessageListenerContainer>endpoint - the endpoint to configureprotected abstract C createContainerInstance()
protected void initializeContainer(C instance)
Subclasses can inherit from this method to apply extra configuration if necessary.
instance - the containe instance to configure.