com.j_spaces.jms

Class GSXAQueueSessionImpl

java.lang.Object

com.j_spaces.jms.GSSessionImpl

com.j_spaces.jms.GSXASessionImpl

com.j_spaces.jms.GSXAQueueSessionImpl

All Implemented Interfaces:

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

public class GSXAQueueSessionImpl
extends GSXASessionImpl
implements javax.jms.XAQueueSession, javax.jms.QueueSession

GigaSpaces implemention of the javax.jms.XAQueueSession interface.

Field Summary

Fields inherited from class com.j_spaces.jms.GSXASessionImpl

xaResource

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
GSXAQueueSessionImpl(GSXAConnectionImpl connection) Creates an instance of GSXAQueueSessionImpl.

Method Summary

Modifier and Type	Method and Description
javax.jms.QueueSession	getQueueSession()

Methods inherited from class com.j_spaces.jms.GSXASessionImpl

commit, getSession, getXAResource, 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

commit, getSession, getTransacted, getXAResource, rollback

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

Methods inherited from interface javax.jms.QueueSession

createBrowser, createBrowser, createQueue, createReceiver, createReceiver, createSender, createTemporaryQueue

Constructor Detail

GSXAQueueSessionImpl

public GSXAQueueSessionImpl(GSXAConnectionImpl connection)
                     throws javax.jms.JMSException

Creates an instance of GSXAQueueSessionImpl.

Parameters:

connection - parent connection

Throws:

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

Method Detail

getQueueSession

public javax.jms.QueueSession getQueueSession()
                                       throws javax.jms.JMSException

Specified by:

getQueueSession in interface javax.jms.XAQueueSession

Throws:

javax.jms.JMSException

See Also:

XAQueueSession.getQueueSession()