public abstract class AbstractJmsListenerContainerFactory<C extends AbstractMessageListenerContainer> extends java.lang.Object implements JmsListenerContainerFactory<C>
JmsListenerContainerFactory
for Spring's base container implementation.AbstractMessageListenerContainer
Modifier and Type | Field and Description |
---|---|
private java.lang.Boolean |
autoStartup |
private java.lang.String |
clientId |
private ConnectionFactory |
connectionFactory |
private DestinationResolver |
destinationResolver |
private ErrorHandler |
errorHandler |
protected Log |
logger |
private MessageConverter |
messageConverter |
private java.lang.Integer |
phase |
private java.lang.Boolean |
pubSubDomain |
private java.lang.Boolean |
replyPubSubDomain |
private java.lang.Integer |
sessionAcknowledgeMode |
private java.lang.Boolean |
sessionTransacted |
private java.lang.Boolean |
subscriptionDurable |
private java.lang.Boolean |
subscriptionShared |
Constructor and Description |
---|
AbstractJmsListenerContainerFactory() |
Modifier and Type | Method and Description |
---|---|
protected abstract C |
createContainerInstance()
Create an empty container instance.
|
C |
createListenerContainer(JmsListenerEndpoint endpoint)
Create a
MessageListenerContainer for the given JmsListenerEndpoint . |
protected void |
initializeContainer(C instance)
Further initialize the specified container.
|
void |
setAutoStartup(boolean autoStartup) |
void |
setClientId(java.lang.String clientId) |
void |
setConnectionFactory(ConnectionFactory connectionFactory) |
void |
setDestinationResolver(DestinationResolver destinationResolver) |
void |
setErrorHandler(ErrorHandler errorHandler) |
void |
setMessageConverter(MessageConverter messageConverter) |
void |
setPhase(int phase) |
void |
setPubSubDomain(java.lang.Boolean pubSubDomain) |
void |
setReplyPubSubDomain(java.lang.Boolean replyPubSubDomain) |
void |
setSessionAcknowledgeMode(java.lang.Integer sessionAcknowledgeMode) |
void |
setSessionTransacted(java.lang.Boolean sessionTransacted) |
void |
setSubscriptionDurable(java.lang.Boolean subscriptionDurable) |
void |
setSubscriptionShared(java.lang.Boolean subscriptionShared) |
protected final Log logger
private ConnectionFactory connectionFactory
private DestinationResolver destinationResolver
private ErrorHandler errorHandler
private MessageConverter messageConverter
private java.lang.Boolean sessionTransacted
private java.lang.Integer sessionAcknowledgeMode
private java.lang.Boolean pubSubDomain
private java.lang.Boolean replyPubSubDomain
private java.lang.Boolean subscriptionDurable
private java.lang.Boolean subscriptionShared
private java.lang.String clientId
private java.lang.Integer phase
private java.lang.Boolean autoStartup
public void setConnectionFactory(ConnectionFactory connectionFactory)
public void setDestinationResolver(DestinationResolver destinationResolver)
public void setErrorHandler(ErrorHandler errorHandler)
public void setMessageConverter(MessageConverter messageConverter)
public void setSessionTransacted(java.lang.Boolean sessionTransacted)
public void setSessionAcknowledgeMode(java.lang.Integer sessionAcknowledgeMode)
public void setPubSubDomain(java.lang.Boolean pubSubDomain)
public void setReplyPubSubDomain(java.lang.Boolean replyPubSubDomain)
public void setSubscriptionDurable(java.lang.Boolean subscriptionDurable)
public void setSubscriptionShared(java.lang.Boolean subscriptionShared)
public void setClientId(java.lang.String clientId)
public void setPhase(int phase)
public void setAutoStartup(boolean autoStartup)
public C createListenerContainer(JmsListenerEndpoint endpoint)
JmsListenerContainerFactory
MessageListenerContainer
for the given JmsListenerEndpoint
.createListenerContainer
in interface JmsListenerContainerFactory<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.