jrun.jms.xa
Class JRunXASessionImpl

jrun.jms.wrapper.enterprise.AbstractSessionWrapper
  |
  +--jrun.jms.xa.JRunXASessionImpl

All Implemented Interfaces:

JRunXASession, SessionWrapper, StateObject

Direct Known Subclasses:

JRunXASessionWrapper

public class JRunXASessionImpl

extends AbstractSessionWrapper

implements JRunXASession

Fields inherited from class jrun.jms.wrapper.enterprise.AbstractSessionWrapper

AUTO_COMMIT_FALSE, AUTO_COMMIT_TRUE, DT_PROCESSING, INITIAL, m_startMsgProcess, STATUS_MESSAGE_PROCESSING, STATUS_READY_FOR_MESSAGE_PROCESSING

Fields inherited from interface jrun.jms.wrapper.enterprise.StateObject

STATUS_CLOSED, STATUS_MARKED_CLOSED, STATUS_STARTED, STATUS_STOPPED, STATUS_UNDEFINED, STATUS_WAIT

Constructor Summary

JRunXASessionImpl()

JRunXASessionImpl(javax.jms.Session session, JRunXAConnection xaConnection)

Method Summary

void	cleanUp()
void	cleanUpSession()
void	close()
void	commit()
javax.jms.Session	getDelegate()
boolean	getTransacted()
javax.jms.XASession	getXADelegate()
javax.transaction.xa.XAResource	getXAResource()
boolean	postMessageProcess(boolean success)
boolean	preMessageProcess()
void	rollback()
void	run()
boolean	sameTransaction(javax.transaction.xa.Xid xid)
void	setConnectionWrapper(ConnectionWrapper cw)
void	setDelegate(javax.jms.Session session)

Methods inherited from class jrun.jms.wrapper.enterprise.AbstractSessionWrapper

autoCommit, autoRollback, createBrowser, createBrowser, createBytesMessage, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createPublisher, createQueue, createReceiver, createReceiver, createSender, createStreamMessage, createSubscriber, createSubscriber, createTemporaryQueue, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, getInvokerType, getMessageListener, getQueueSession, getSessionStatus, getTopicSession, getTransactionInProgress, handleTransaction, isAutoCommit, isClosed, isRestricted, markClosed, recover, SetInitialTransactionAttributes, setInvokerType, setMessageListener, setSessionStatus, setTransactionInProgress, TransactioninProgress, unsubscribe

Methods inherited from interface jrun.jms.wrapper.enterprise.SessionWrapper

SetInitialTransactionAttributes, TransactioninProgress

Constructor Detail

JRunXASessionImpl

public JRunXASessionImpl()

JRunXASessionImpl

public JRunXASessionImpl(javax.jms.Session session,
                         JRunXAConnection xaConnection)
                  throws javax.jms.JMSException

Method Detail

setDelegate

public void setDelegate(javax.jms.Session session)
                 throws javax.jms.JMSException

Specified by:

setDelegate in interface SessionWrapper

setConnectionWrapper

public void setConnectionWrapper(ConnectionWrapper cw)

Specified by:

setConnectionWrapper in interface SessionWrapper

getDelegate

public javax.jms.Session getDelegate()

Specified by:

getDelegate in interface SessionWrapper

getXADelegate

public javax.jms.XASession getXADelegate()

Specified by:

getXADelegate in interface SessionWrapper

getXAResource

public javax.transaction.xa.XAResource getXAResource()

Specified by:

getXAResource in interface SessionWrapper

commit

public void commit()
            throws javax.jms.JMSException

Overrides:

commit in class AbstractSessionWrapper

rollback

public void rollback()
              throws javax.jms.JMSException

Overrides:

rollback in class AbstractSessionWrapper

getTransacted

public boolean getTransacted()
                      throws javax.jms.JMSException

Overrides:

getTransacted in class AbstractSessionWrapper

close

public void close()
           throws javax.jms.JMSException

Specified by:

close in interface SessionWrapper

Overrides:

close in class AbstractSessionWrapper

run

public void run()

Overrides:

run in class AbstractSessionWrapper

cleanUpSession

public void cleanUpSession()
                    throws javax.jms.JMSException

Specified by:

cleanUpSession in interface JRunXASession

cleanUp

public void cleanUp()

sameTransaction

public boolean sameTransaction(javax.transaction.xa.Xid xid)
                        throws javax.jms.JMSException

Specified by:

sameTransaction in interface SessionWrapper

preMessageProcess

public boolean preMessageProcess()
                          throws javax.jms.JMSException

Specified by:

preMessageProcess in interface SessionWrapper

postMessageProcess

public boolean postMessageProcess(boolean success)
                           throws javax.jms.JMSException

Specified by:

postMessageProcess in interface SessionWrapper