public class TomEEConnection
extends ActiveMQConnection
| Constructor and Description |
|---|
TomEEConnection(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) |
public TomEEConnection(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