|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.springframework.jms.listener.endpoint.JmsActivationSpecConfig
public class JmsActivationSpecConfig
Common configuration object for activating a JMS message endpoint. Gets converted into a provider-specific JCA 1.5 ActivationSpec object for activating the endpoint.
Typically used in combination with JmsMessageEndpointManager
,
but not tied to it.
JmsActivationSpecFactory
,
JmsMessageEndpointManager.setActivationSpecConfig(org.springframework.jms.listener.endpoint.JmsActivationSpecConfig)
,
ResourceAdapter.endpointActivation(javax.resource.spi.endpoint.MessageEndpointFactory, javax.resource.spi.ActivationSpec)
Constructor Summary | |
---|---|
JmsActivationSpecConfig()
|
Method Summary | |
---|---|
int |
getAcknowledgeMode()
Return the JMS acknowledgement mode to use. |
String |
getClientId()
|
String |
getDestinationName()
|
String |
getDurableSubscriptionName()
|
int |
getMaxConcurrency()
Return the maximum number of consumers/sessions to use. |
String |
getMessageSelector()
|
int |
getPrefetchSize()
Return the maximum number of messages to load into a session. |
boolean |
isPubSubDomain()
|
boolean |
isSubscriptionDurable()
|
void |
setAcknowledgeMode(int acknowledgeMode)
Set the JMS acknowledgement mode to use. |
void |
setAcknowledgeModeName(String constantName)
Set the JMS acknowledgement mode by the name of the corresponding constant in the JMS Session interface, e.g. |
void |
setClientId(String clientId)
|
void |
setConcurrency(String concurrency)
Specify concurrency limits via a "lower-upper" String, e.g. |
void |
setDestinationName(String destinationName)
|
void |
setDurableSubscriptionName(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 |
setMessageSelector(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 |
setSubscriptionDurable(boolean subscriptionDurable)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public JmsActivationSpecConfig()
Method Detail |
---|
public void setDestinationName(String destinationName)
public String getDestinationName()
public void setPubSubDomain(boolean pubSubDomain)
public boolean isPubSubDomain()
public void setSubscriptionDurable(boolean subscriptionDurable)
public boolean isSubscriptionDurable()
public void setDurableSubscriptionName(String durableSubscriptionName)
public String getDurableSubscriptionName()
public void setClientId(String clientId)
public String getClientId()
public void setMessageSelector(String messageSelector)
public String getMessageSelector()
public void setAcknowledgeModeName(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 constantSession.AUTO_ACKNOWLEDGE
,
Session.CLIENT_ACKNOWLEDGE
,
Session.DUPS_OK_ACKNOWLEDGE
,
Session.SESSION_TRANSACTED
,
StandardJmsActivationSpecFactory
,
DefaultJmsActivationSpecFactory
public void setAcknowledgeMode(int acknowledgeMode)
Session.AUTO_ACKNOWLEDGE
,
Session.CLIENT_ACKNOWLEDGE
,
Session.DUPS_OK_ACKNOWLEDGE
,
Session.SESSION_TRANSACTED
public int getAcknowledgeMode()
public void setConcurrency(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()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |