public abstract class AbstractRabbitListenerContainerFactory<C extends AbstractMessageListenerContainer> extends Object implements RabbitListenerContainerFactory<C>
RabbitListenerContainerFactory
for Spring's base container implementation.AbstractMessageListenerContainer
Modifier and Type | Field and Description |
---|---|
protected 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(AcknowledgeMode acknowledgeMode) |
void |
setAutoStartup(Boolean autoStartup) |
void |
setChannelTransacted(Boolean channelTransacted) |
void |
setConnectionFactory(ConnectionFactory connectionFactory) |
void |
setErrorHandler(ErrorHandler errorHandler) |
void |
setMessageConverter(MessageConverter messageConverter) |
void |
setPhase(int phase) |
protected final org.apache.commons.logging.Log logger
protected final AtomicInteger counter
public AbstractRabbitListenerContainerFactory()
public void setConnectionFactory(ConnectionFactory connectionFactory)
connectionFactory
- The connection factory.RabbitAccessor.setConnectionFactory(ConnectionFactory)
public void setErrorHandler(ErrorHandler errorHandler)
errorHandler
- The error handler.AbstractMessageListenerContainer.setErrorHandler(org.springframework.util.ErrorHandler)
public void setMessageConverter(MessageConverter messageConverter)
messageConverter
- the message converter to useAbstractMessageListenerContainer.setMessageConverter(MessageConverter)
public void setAcknowledgeMode(AcknowledgeMode acknowledgeMode)
acknowledgeMode
- the acknowledge mode to set. Defaults to AcknowledgeMode.AUTO
AbstractMessageListenerContainer.setAcknowledgeMode(AcknowledgeMode)
public void setChannelTransacted(Boolean channelTransacted)
channelTransacted
- the flag value to setRabbitAccessor.setChannelTransacted(boolean)
public void setAutoStartup(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)
RabbitListenerContainerFactory
MessageListenerContainer
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.