public class JmsActivationSpecConfig
extends java.lang.Object
Typically used in combination with JmsMessageEndpointManager
,
but not tied to it.
JmsActivationSpecFactory
,
JmsMessageEndpointManager.setActivationSpecConfig(org.springframework.jms.listener.endpoint.JmsActivationSpecConfig)
,
javax.resource.spi.ResourceAdapter#endpointActivation
Modifier and Type | Field and Description |
---|---|
private int |
acknowledgeMode |
private java.lang.String |
clientId |
private java.lang.String |
destinationName |
private int |
maxConcurrency |
private MessageConverter |
messageConverter |
private java.lang.String |
messageSelector |
private int |
prefetchSize |
private boolean |
pubSubDomain |
private java.lang.Boolean |
replyPubSubDomain |
private static Constants |
sessionConstants
Constants instance for javax.jms.Session
|
private boolean |
subscriptionDurable |
private java.lang.String |
subscriptionName |
private boolean |
subscriptionShared |
Constructor and Description |
---|
JmsActivationSpecConfig() |
Modifier and Type | Method and Description |
---|---|
int |
getAcknowledgeMode()
Return the JMS acknowledgement mode to use.
|
java.lang.String |
getClientId() |
java.lang.String |
getDestinationName() |
java.lang.String |
getDurableSubscriptionName() |
int |
getMaxConcurrency()
Return the maximum number of consumers/sessions to use.
|
MessageConverter |
getMessageConverter()
Return the
MessageConverter to use, if any. |
java.lang.String |
getMessageSelector() |
int |
getPrefetchSize()
Return the maximum number of messages to load into a session.
|
java.lang.String |
getSubscriptionName() |
boolean |
isPubSubDomain() |
boolean |
isReplyPubSubDomain() |
boolean |
isSubscriptionDurable() |
boolean |
isSubscriptionShared() |
void |
setAcknowledgeMode(int acknowledgeMode)
Set the JMS acknowledgement mode to use.
|
void |
setAcknowledgeModeName(java.lang.String constantName)
Set the JMS acknowledgement mode by the name of the corresponding constant
in the JMS
Session interface, e.g. |
void |
setClientId(java.lang.String clientId) |
void |
setConcurrency(java.lang.String concurrency)
Specify concurrency limits via a "lower-upper" String, e.g.
|
void |
setDestinationName(java.lang.String destinationName) |
void |
setDurableSubscriptionName(java.lang.String durableSubscriptionName) |
void |
setMaxConcurrency(int maxConcurrency)
Specify the maximum number of consumers/sessions to use, effectively
controlling the number of concurrent invocations on the target listener.
|
void |
setMessageConverter(MessageConverter messageConverter)
Set the
MessageConverter strategy for converting JMS Messages. |
void |
setMessageSelector(java.lang.String messageSelector) |
void |
setPrefetchSize(int prefetchSize)
Specify the maximum number of messages to load into a session
(a kind of batch size).
|
void |
setPubSubDomain(boolean pubSubDomain) |
void |
setReplyPubSubDomain(boolean replyPubSubDomain) |
void |
setSubscriptionDurable(boolean subscriptionDurable) |
void |
setSubscriptionName(java.lang.String subscriptionName) |
void |
setSubscriptionShared(boolean subscriptionShared) |
private static final Constants sessionConstants
private java.lang.String destinationName
private boolean pubSubDomain
private java.lang.Boolean replyPubSubDomain
private boolean subscriptionDurable
private boolean subscriptionShared
private java.lang.String subscriptionName
private java.lang.String clientId
private java.lang.String messageSelector
private int acknowledgeMode
private int maxConcurrency
private int prefetchSize
private MessageConverter messageConverter
public void setDestinationName(java.lang.String destinationName)
public java.lang.String getDestinationName()
public void setPubSubDomain(boolean pubSubDomain)
public boolean isPubSubDomain()
public void setReplyPubSubDomain(boolean replyPubSubDomain)
public boolean isReplyPubSubDomain()
public void setSubscriptionDurable(boolean subscriptionDurable)
public boolean isSubscriptionDurable()
public void setSubscriptionShared(boolean subscriptionShared)
public boolean isSubscriptionShared()
public void setSubscriptionName(java.lang.String subscriptionName)
public java.lang.String getSubscriptionName()
public void setDurableSubscriptionName(java.lang.String durableSubscriptionName)
public java.lang.String getDurableSubscriptionName()
public void setClientId(java.lang.String clientId)
public java.lang.String getClientId()
public void setMessageSelector(java.lang.String messageSelector)
public java.lang.String getMessageSelector()
public void setAcknowledgeModeName(java.lang.String constantName)
Session
interface, e.g. "CLIENT_ACKNOWLEDGE".
Note that JCA resource adapters generally only support auto and dups-ok
(see Spring's StandardJmsActivationSpecFactory
). ActiveMQ also
supports "SESSION_TRANSACTED" in the form of RA-managed transactions
(automatically translated by Spring's DefaultJmsActivationSpecFactory
.
constantName
- the name of the Session
acknowledge mode constantjavax.jms.Session#AUTO_ACKNOWLEDGE
,
javax.jms.Session#CLIENT_ACKNOWLEDGE
,
javax.jms.Session#DUPS_OK_ACKNOWLEDGE
,
javax.jms.Session#SESSION_TRANSACTED
,
StandardJmsActivationSpecFactory
,
DefaultJmsActivationSpecFactory
public void setAcknowledgeMode(int acknowledgeMode)
javax.jms.Session#AUTO_ACKNOWLEDGE
,
javax.jms.Session#CLIENT_ACKNOWLEDGE
,
javax.jms.Session#DUPS_OK_ACKNOWLEDGE
,
javax.jms.Session#SESSION_TRANSACTED
public int getAcknowledgeMode()
public void setConcurrency(java.lang.String concurrency)
JCA listener containers will always scale from zero to the given upper limit. A specified lower limit will effectively be ignored.
This property is primarily supported for configuration compatibility with
DefaultMessageListenerContainer
.
For this activation config, generally use setMaxConcurrency(int)
instead.
public void setMaxConcurrency(int maxConcurrency)
public int getMaxConcurrency()
public void setPrefetchSize(int prefetchSize)
public int getPrefetchSize()
public void setMessageConverter(MessageConverter messageConverter)
MessageConverter
strategy for converting JMS Messages.messageConverter
- the message converter to usepublic MessageConverter getMessageConverter()
MessageConverter
to use, if any.