public final class HornetQXAConnection extends HornetQConnection implements XATopicConnection, 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
Constructor and Description |
---|
HornetQXAConnection(String username,
String password,
int connectionType,
String clientID,
int dupsOKBatchSize,
int transactionBatchSize,
ClientSessionFactory sessionFactory) |
Modifier and Type | Method and Description |
---|---|
XAQueueSession |
createXAQueueSession()
Creates an
XAQueueSession object. |
XASession |
createXASession()
Creates an
XASession object. |
XATopicSession |
createXATopicSession()
Creates an
XATopicSession object. |
protected boolean |
isXA() |
addTemporaryQueue, authorize, checkClosed, close, containsTemporaryQueue, createConnectionConsumer, createConnectionConsumer, createConnectionConsumer, createDurableConnectionConsumer, createHQSession, createNonXAQueueSession, createNonXASession, createNonXATopicSession, createQueueSession, createSession, createSessionInternal, createTopicSession, finalize, getClientID, getExceptionListener, getFailoverListener, getInitialSession, getMetaData, getUID, hasNoLocal, removeSession, removeTemporaryQueue, setClientID, setExceptionListener, setFailoverListener, setHasNoLocal, setReference, signalStopToAllSessions, start, stop
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createTopicSession
createConnectionConsumer, createDurableConnectionConsumer
createQueueSession
createSession
createConnectionConsumer
close, createConnectionConsumer, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop
public HornetQXAConnection(String username, String password, int connectionType, String clientID, int dupsOKBatchSize, int transactionBatchSize, ClientSessionFactory sessionFactory)
public XASession createXASession() throws JMSException
XAConnection
XASession
object.createXASession
in interface XAConnection
XASession
JMSException
- if the XAConnection
object
fails to create an XASession
due to
some internal error.public XAQueueSession createXAQueueSession() throws JMSException
XAQueueConnection
XAQueueSession
object.createXAQueueSession
in interface XAQueueConnection
XAQueueSession
JMSException
- if the XAQueueConnection
object
fails to create an XA queue session due to some
internal error.public XATopicSession createXATopicSession() throws JMSException
XATopicConnection
XATopicSession
object.createXATopicSession
in interface XATopicConnection
JMSException
- if the XATopicConnection
object
fails to create an XA topic session due to some
internal error.protected final boolean isXA()
isXA
in class HornetQConnection
Copyright © 2013 JBoss by Red Hat. All Rights Reserved.