com.j_spaces.jms

Class GSXASessionImpl

java.lang.Object

com.j_spaces.jms.GSSessionImpl

com.j_spaces.jms.GSXASessionImpl

All Implemented Interfaces:

Runnable, javax.jms.QueueSession, javax.jms.Session, javax.jms.TopicSession, javax.jms.XASession

Direct Known Subclasses:

GSXAQueueSessionImpl, GSXATopicSessionImpl

public class GSXASessionImpl
extends GSSessionImpl
implements javax.jms.XASession

GigaSpaces implemention of the javax.jms.XASession interface.

Field Summary

Fields

Modifier and Type	Field and Description
protected XAResourceJMSImpl	xaResource The XAResource of the session.

Fields inherited from class com.j_spaces.jms.GSSessionImpl

_tx, m_browsers, m_closed, m_closing, m_consumers, m_isQueue, m_producers, m_stopped, sentMessages, txLeaseTime, unackedMessages

Fields inherited from interface javax.jms.Session

AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED

Constructor Summary

Constructors

Constructor and Description
GSXASessionImpl(GSXAConnectionImpl conn) Creates an instance of GSXASessionImpl.

Method Summary

Modifier and Type	Method and Description
void	commit() Commits all messages done in this transaction and releases any locks currently held.
javax.jms.Session	getSession()
XAResource	getXAResource()
void	rollback()

Methods inherited from class com.j_spaces.jms.GSSessionImpl

addBrowser, addConsumer, addProducer, close, createBrowser, createBrowser, createBytesMessage, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createPublisher, createQueue, createReceiver, createReceiver, createSender, createStreamMessage, createSubscriber, createSubscriber, createTemporaryQueue, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, ensureTX, getAcknowledgeMode, getConn, getConsumersC, getJMSProviderName, getMessageListener, getMessagesC, getNumOfConsumedMsg, getNumOfProducedMsg, getProducersC, getRandomInt, getSessionID, getTransacted, getTransaction, isClosed, recover, removeBrower, removeConsumer, removeProducer, run, setConsumersC, setMessageListener, setMessagesC, setProducersC, setSessionID, toString, unsubscribe

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface javax.jms.XASession

getTransacted

Methods inherited from interface javax.jms.Session

close, createBrowser, createBrowser, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createQueue, createStreamMessage, createTemporaryQueue, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, getAcknowledgeMode, getMessageListener, recover, run, setMessageListener, unsubscribe

Field Detail

xaResource

protected XAResourceJMSImpl xaResource

The XAResource of the session.

Constructor Detail

GSXASessionImpl

public GSXASessionImpl(GSXAConnectionImpl conn)
                throws javax.jms.JMSException

Creates an instance of GSXASessionImpl.

Parameters:

conn - the connection of the session.

Throws:

javax.jms.JMSException - if failed to create the session.

Method Detail

getSession

public javax.jms.Session getSession()
                             throws javax.jms.JMSException

Specified by:

getSession in interface javax.jms.XASession

Throws:

javax.jms.JMSException

See Also:

XASession.getSession()

getXAResource

public XAResource getXAResource()

Specified by:

getXAResource in interface javax.jms.XASession

See Also:

XASession.getXAResource()

rollback

public void rollback()
              throws javax.jms.JMSException

Specified by:

rollback in interface javax.jms.Session

Specified by:

rollback in interface javax.jms.XASession

Overrides:

rollback in class GSSessionImpl

Throws:

javax.jms.JMSException

See Also:

XASession.rollback()

commit

public void commit()
            throws javax.jms.JMSException

Description copied from class: GSSessionImpl

Commits all messages done in this transaction and releases any locks currently held.

Specified by:

commit in interface javax.jms.Session

Specified by:

commit in interface javax.jms.XASession

Overrides:

commit in class GSSessionImpl

Throws:

javax.jms.JMSException

See Also:

XASession.commit()