C
- the container typepublic 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 QosSettings |
replyQosSettings |
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 |
setReplyQosSettings(QosSettings replyQosSettings) |
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
@Nullable private ConnectionFactory connectionFactory
@Nullable private DestinationResolver destinationResolver
@Nullable private ErrorHandler errorHandler
@Nullable private MessageConverter messageConverter
@Nullable private java.lang.Boolean sessionTransacted
@Nullable private java.lang.Integer sessionAcknowledgeMode
@Nullable private java.lang.Boolean pubSubDomain
@Nullable private java.lang.Boolean replyPubSubDomain
@Nullable private QosSettings replyQosSettings
@Nullable private java.lang.Boolean subscriptionDurable
@Nullable private java.lang.Boolean subscriptionShared
@Nullable private java.lang.String clientId
@Nullable private java.lang.Integer phase
@Nullable 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 setReplyQosSettings(QosSettings replyQosSettings)
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.