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.
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 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 |
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.
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()