public class TomEEXASession
extends ActiveMQXASession
Constructor and Description |
---|
TomEEXASession(ActiveMQXAConnection connection,
SessionId sessionId,
int theAcknowlegeMode,
boolean dispatchAsync) |
Modifier and Type | Method and Description |
---|---|
MessageConsumer |
createDurableConsumer(Topic topic,
java.lang.String name) |
MessageConsumer |
createDurableConsumer(Topic topic,
java.lang.String name,
java.lang.String messageSelector,
boolean noLocal) |
MessageConsumer |
createSharedConsumer(Topic topic,
java.lang.String sharedSubscriptionName) |
MessageConsumer |
createSharedConsumer(Topic topic,
java.lang.String sharedSubscriptionName,
java.lang.String messageSelector) |
MessageConsumer |
createSharedDurableConsumer(Topic topic,
java.lang.String name) |
MessageConsumer |
createSharedDurableConsumer(Topic topic,
java.lang.String name,
java.lang.String messageSelector) |
protected void |
doStartTransaction() |
public TomEEXASession(ActiveMQXAConnection connection, SessionId sessionId, int theAcknowlegeMode, boolean dispatchAsync) throws JMSException
JMSException
public MessageConsumer createDurableConsumer(Topic topic, java.lang.String name) throws JMSException
JMSException
public MessageConsumer createDurableConsumer(Topic topic, java.lang.String name, java.lang.String messageSelector, boolean noLocal) throws JMSException
JMSException
public MessageConsumer createSharedConsumer(Topic topic, java.lang.String sharedSubscriptionName) throws JMSException
JMSException
public MessageConsumer createSharedConsumer(Topic topic, java.lang.String sharedSubscriptionName, java.lang.String messageSelector) throws JMSException
JMSException
public MessageConsumer createSharedDurableConsumer(Topic topic, java.lang.String name) throws JMSException
JMSException
public MessageConsumer createSharedDurableConsumer(Topic topic, java.lang.String name, java.lang.String messageSelector) throws JMSException
JMSException
protected void doStartTransaction() throws JMSException
JMSException