public class TomEEXAConnection
extends ActiveMQXAConnection
| Modifier | Constructor and Description |
|---|---|
protected |
TomEEXAConnection(Transport transport,
IdGenerator clientIdGenerator,
IdGenerator connectionIdGenerator,
JMSStatsImpl factoryStats) |
| Modifier and Type | Method and Description |
|---|---|
Session |
createSession() |
Session |
createSession(boolean transacted,
int acknowledgeMode) |
Session |
createSession(int sessionMode) |
ConnectionConsumer |
createSharedConnectionConsumer(Topic topic,
java.lang.String subscriptionName,
java.lang.String messageSelector,
ServerSessionPool sessionPool,
int maxMessages) |
ConnectionConsumer |
createSharedDurableConnectionConsumer(Topic topic,
java.lang.String subscriptionName,
java.lang.String messageSelector,
ServerSessionPool sessionPool,
int maxMessages) |
protected TomEEXAConnection(Transport transport,
IdGenerator clientIdGenerator,
IdGenerator connectionIdGenerator,
JMSStatsImpl factoryStats)
throws java.lang.Exception
java.lang.Exceptionpublic Session createSession(boolean transacted,
int acknowledgeMode)
throws JMSException
JMSExceptionpublic Session createSession(int sessionMode)
throws JMSException
JMSExceptionpublic Session createSession()
throws JMSException
JMSExceptionpublic ConnectionConsumer createSharedDurableConnectionConsumer(Topic topic,
java.lang.String subscriptionName,
java.lang.String messageSelector,
ServerSessionPool sessionPool,
int maxMessages)
throws JMSException
JMSExceptionpublic ConnectionConsumer createSharedConnectionConsumer(Topic topic,
java.lang.String subscriptionName,
java.lang.String messageSelector,
ServerSessionPool sessionPool,
int maxMessages)
throws JMSException
JMSException