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.Exception
public Session createSession(boolean transacted, int acknowledgeMode) throws JMSException
JMSException
public Session createSession(int sessionMode) throws JMSException
JMSException
public Session createSession() throws JMSException
JMSException
public ConnectionConsumer createSharedDurableConnectionConsumer(Topic topic, java.lang.String subscriptionName, java.lang.String messageSelector, ServerSessionPool sessionPool, int maxMessages) throws JMSException
JMSException
public ConnectionConsumer createSharedConnectionConsumer(Topic topic, java.lang.String subscriptionName, java.lang.String messageSelector, ServerSessionPool sessionPool, int maxMessages) throws JMSException
JMSException