com.j_spaces.jms
Class GSXASessionImpl

java.lang.Object
  com.j_spaces.jms.GSSessionImpl
      com.j_spaces.jms.GSXASessionImpl

All Implemented Interfaces:

Runnable, QueueSession, Session, TopicSession, XASession

Direct Known Subclasses:

GSXAQueueSessionImpl, GSXATopicSessionImpl

public class GSXASessionImpl
extends GSSessionImpl
implements XASession

GigaSpaces implemention of the javax.jms.XASession interface.

Field Summary

Fields inherited from class com.j_spaces.jms.GSSessionImpl

txLeaseTime

Fields inherited from interface javax.jms.Session

AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED

Constructor Summary

GSXASessionImpl(GSXAConnectionImpl conn)
Creates an instance of GSXASessionImpl.

Method Summary

void	commit() Commits all messages done in this transaction and releases any locks currently held.
Session	getSession()
XAResource	getXAResource()
void	rollback() API method for m_tx rollback Calling the space LocalTransactionManager m_tx.abort()

Methods inherited from class com.j_spaces.jms.GSSessionImpl

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, getAcknowledgeMode, getConsumersC, getJMSProviderName, getMessageListener, getMessagesC, getNumOfConsumedMsg, getNumOfProducedMsg, getProducersC, getSessionID, getTransacted, recover, run, setConsumersC, setMessageListener, setMessagesC, setProducersC, setSessionID, toString, unsubscribe

Methods inherited from class java.lang.Object

equals, 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

Constructor Detail

GSXASessionImpl

public GSXASessionImpl(GSXAConnectionImpl conn)
                throws JMSException

Creates an instance of GSXASessionImpl.

Parameters:

conn - the connection of the session.

isTransacted - true if the session is transacted.

acknowledgeMode - - acknowledge mode in case the session is not transacted.

Throws:

JMSException - if failed to create the session.

Method Detail

getSession

public Session getSession()
                   throws JMSException

Specified by:

getSession in interface XASession

Throws:

JMSException

getXAResource

public XAResource getXAResource()

Specified by:

getXAResource in interface XASession

rollback

public void rollback()
              throws JMSException

Description copied from class: GSSessionImpl

API method for m_tx rollback Calling the space LocalTransactionManager m_tx.abort()

Specified by:

rollback in interface Session

Specified by:

rollback in interface XASession

Overrides:

rollback in class GSSessionImpl

Throws:

JMSException

See Also:

Session.rollback()

commit

public void commit()
            throws JMSException

Description copied from class: GSSessionImpl

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

Specified by:

commit in interface Session

Specified by:

commit in interface XASession

Overrides:

commit in class GSSessionImpl

Throws:

JMSException

See Also:

Session.commit()