public final class HornetQXAConnection extends HornetQConnection implements javax.jms.XATopicConnection, javax.jms.XAQueueConnection
The flat implementation of XATopicConnection
and XAQueueConnection
is per design,
following common practices of JMS 1.1.
CONNECTION_ID_PROPERTY_NAME, EXCEPTION_DISCONNECT, EXCEPTION_FAILOVER, TYPE_GENERIC_CONNECTION, TYPE_QUEUE_CONNECTION, TYPE_TOPIC_CONNECTION
threadAwareContext
Constructor and Description |
---|
HornetQXAConnection(String username,
String password,
int connectionType,
String clientID,
int dupsOKBatchSize,
int transactionBatchSize,
ClientSessionFactory sessionFactory) |
Modifier and Type | Method and Description |
---|---|
javax.jms.XAQueueSession |
createXAQueueSession() |
javax.jms.XASession |
createXASession() |
javax.jms.XATopicSession |
createXATopicSession() |
protected boolean |
isXA() |
addKnownDestination, addTemporaryQueue, authorize, checkAck, checkClosed, close, containsKnownDestination, containsTemporaryQueue, createConnectionConsumer, createConnectionConsumer, createConnectionConsumer, createDurableConnectionConsumer, createHQSession, createNonXAQueueSession, createNonXASession, createNonXATopicSession, createQueueSession, createSession, createSession, createSession, createSessionInternal, createSharedConnectionConsumer, createSharedDurableConnectionConsumer, createTopicSession, finalize, getClientID, getExceptionListener, getFailoverListener, getInitialSession, getMetaData, getUID, hasNoLocal, isStarted, removeSession, removeTemporaryQueue, setClientID, setExceptionListener, setFailoverListener, setHasNoLocal, setReference, signalStopToAllSessions, start, stop
closeFromContext, createContext, createXAContext, getThreadAwareContext, incrementRefCounter
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public HornetQXAConnection(String username, String password, int connectionType, String clientID, int dupsOKBatchSize, int transactionBatchSize, ClientSessionFactory sessionFactory)
public javax.jms.XASession createXASession() throws javax.jms.JMSException
createXASession
in interface javax.jms.XAConnection
javax.jms.JMSException
public javax.jms.XAQueueSession createXAQueueSession() throws javax.jms.JMSException
createXAQueueSession
in interface javax.jms.XAQueueConnection
javax.jms.JMSException
public javax.jms.XATopicSession createXATopicSession() throws javax.jms.JMSException
createXATopicSession
in interface javax.jms.XATopicConnection
javax.jms.JMSException
protected boolean isXA()
isXA
in class HornetQConnection
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.