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
JMSExceptionpublic MessageConsumer createDurableConsumer(Topic topic,
java.lang.String name)
throws JMSException
JMSExceptionpublic MessageConsumer createDurableConsumer(Topic topic,
java.lang.String name,
java.lang.String messageSelector,
boolean noLocal)
throws JMSException
JMSExceptionpublic MessageConsumer createSharedConsumer(Topic topic,
java.lang.String sharedSubscriptionName)
throws JMSException
JMSExceptionpublic MessageConsumer createSharedConsumer(Topic topic,
java.lang.String sharedSubscriptionName,
java.lang.String messageSelector)
throws JMSException
JMSExceptionpublic MessageConsumer createSharedDurableConsumer(Topic topic,
java.lang.String name)
throws JMSException
JMSExceptionpublic MessageConsumer createSharedDurableConsumer(Topic topic,
java.lang.String name,
java.lang.String messageSelector)
throws JMSException
JMSExceptionprotected void doStartTransaction()
throws JMSException
JMSException