org.objectweb.joram.client.jms
Class XAQueueConnection

java.lang.Object
  org.objectweb.joram.client.jms.Connection
      org.objectweb.joram.client.jms.QueueConnection
          org.objectweb.joram.client.jms.XAQueueConnection

All Implemented Interfaces:

javax.jms.Connection, javax.jms.QueueConnection, javax.jms.XAConnection, javax.jms.XAQueueConnection

public class XAQueueConnection
extends QueueConnection
implements javax.jms.XAQueueConnection

Implements the javax.jms.XAQueueConnection interface.

Field Summary

Fields inherited from class org.objectweb.joram.client.jms.Connection

logger

Constructor Summary

XAQueueConnection(FactoryParameters factoryParameters, RequestChannel requestChannel)
Creates an XAQueueConnection instance.

Method Summary

javax.jms.QueueSession	createQueueSession(boolean transacted, int acknowledgeMode) API method.
javax.jms.Session	createSession(boolean transacted, int acknowledgeMode) Method inherited from interface XAConnection.
javax.jms.XAQueueSession	createXAQueueSession() API method.
javax.jms.XASession	createXASession() Method inherited from interface XAConnection.
XAResourceMngr	getXAResourceMngr() return XAResourceMngr of this connection.

Methods inherited from class org.objectweb.joram.client.jms.QueueConnection

createConnectionConsumer, createDurableConnectionConsumer

Methods inherited from class org.objectweb.joram.client.jms.Connection

addSession, checkClosed, cleanup, close, createConnectionConsumer, equals, getAsyncSend, getClientID, getExceptionListener, getImplicitAck, getInInterceptors, getMetaData, getOutInterceptors, getOutLocalAddress, getOutLocalPort, getQueueMessageReadMax, getRequestMultiplexer, getTopicAckBufferMax, getTopicActivationThreshold, getTopicPassivationThreshold, getTxPendingTimer, hashCode, setClientID, setExceptionListener, start, stop, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface javax.jms.QueueConnection

createConnectionConsumer

Methods inherited from interface javax.jms.Connection

close, createConnectionConsumer, createDurableConnectionConsumer, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop

Constructor Detail

XAQueueConnection

public XAQueueConnection(FactoryParameters factoryParameters,
                         RequestChannel requestChannel)
                  throws javax.jms.JMSException

Creates an XAQueueConnection instance.

Parameters:

factoryParameters - The factory parameters.

requestChannel - The actual connection to wrap.

Throws:

JMSSecurityException - If the user identification is incorrect.

javax.jms.IllegalStateException - If the server is not listening.

javax.jms.JMSException

Method Detail

createQueueSession

public javax.jms.QueueSession createQueueSession(boolean transacted,
                                                 int acknowledgeMode)
                                          throws javax.jms.JMSException

API method.

Specified by:

createQueueSession in interface javax.jms.QueueConnection

Specified by:

createQueueSession in interface javax.jms.XAQueueConnection

Overrides:

createQueueSession in class QueueConnection

Throws:

javax.jms.IllegalStateException - If the connection is closed.

javax.jms.JMSException - In case of an invalid acknowledge mode.

createXAQueueSession

public javax.jms.XAQueueSession createXAQueueSession()
                                              throws javax.jms.JMSException

API method.

Specified by:

createXAQueueSession in interface javax.jms.XAQueueConnection

Throws:

javax.jms.IllegalStateException - If the connection is closed.

javax.jms.JMSException

createSession

public javax.jms.Session createSession(boolean transacted,
                                       int acknowledgeMode)
                                throws javax.jms.JMSException

Method inherited from interface XAConnection.

Specified by:

createSession in interface javax.jms.Connection

Specified by:

createSession in interface javax.jms.XAConnection

Overrides:

createSession in class Connection

Throws:

javax.jms.IllegalStateException - If the connection is closed.

javax.jms.JMSException - In case of an invalid acknowledge mode.

createXASession

public javax.jms.XASession createXASession()
                                    throws javax.jms.JMSException

Method inherited from interface XAConnection.

Specified by:

createXASession in interface javax.jms.XAConnection

Throws:

javax.jms.IllegalStateException - If the connection is closed.

javax.jms.JMSException

getXAResourceMngr

public XAResourceMngr getXAResourceMngr()

return XAResourceMngr of this connection. see connector