jrun.jms.wrapper.enterprise
Class JRunXASessionWrapper

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

All Implemented Interfaces:

JRunXASession, SessionWrapper, StateObject

Direct Known Subclasses:

JRunXARestrictedSessionWrapper

public class JRunXASessionWrapper

extends JRunXASessionImpl

implements SessionWrapper

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

JRunXASessionWrapper()

Method Summary

javax.jms.TopicSubscriber	createDurableSubscriber(javax.jms.Topic topic, java.lang.String name)
javax.jms.TopicSubscriber	createDurableSubscriber(javax.jms.Topic topic, java.lang.String name, java.lang.String messageSelector, boolean noLocal)
javax.jms.TopicPublisher	createPublisher(javax.jms.Topic topic)
javax.jms.QueueReceiver	createReceiver(javax.jms.Queue queue)
javax.jms.QueueReceiver	createReceiver(javax.jms.Queue queue, java.lang.String messageSelector)
javax.jms.QueueSender	createSender(javax.jms.Queue queue)
javax.jms.TopicSubscriber	createSubscriber(javax.jms.Topic topic)
javax.jms.TopicSubscriber	createSubscriber(javax.jms.Topic topic, java.lang.String messageSelector, boolean noLocal)
boolean	postMessageProcess(boolean success)
boolean	preMessageProcess()

Methods inherited from class jrun.jms.xa.JRunXASessionImpl

cleanUp, cleanUpSession, close, commit, getDelegate, getTransacted, getXADelegate, getXAResource, rollback, run, sameTransaction, setConnectionWrapper, setDelegate

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

autoCommit, autoRollback, createBrowser, createBrowser, createBytesMessage, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createQueue, createStreamMessage, 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

close, getDelegate, getXADelegate, getXAResource, sameTransaction, setConnectionWrapper, setDelegate, SetInitialTransactionAttributes, TransactioninProgress

Constructor Detail

JRunXASessionWrapper

public JRunXASessionWrapper()

Method Detail

createSender

public javax.jms.QueueSender createSender(javax.jms.Queue queue)
                                   throws javax.jms.JMSException

Overrides:

createSender in class AbstractSessionWrapper

createReceiver

public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue)
                                       throws javax.jms.JMSException

Overrides:

createReceiver in class AbstractSessionWrapper

createReceiver

public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue,
                                              java.lang.String messageSelector)
                                       throws javax.jms.JMSException

Overrides:

createReceiver in class AbstractSessionWrapper

createPublisher

public javax.jms.TopicPublisher createPublisher(javax.jms.Topic topic)
                                         throws javax.jms.JMSException

Overrides:

createPublisher in class AbstractSessionWrapper

createSubscriber

public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic)
                                           throws javax.jms.JMSException

Overrides:

createSubscriber in class AbstractSessionWrapper

createSubscriber

public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic,
                                                  java.lang.String messageSelector,
                                                  boolean noLocal)
                                           throws javax.jms.JMSException

Overrides:

createSubscriber in class AbstractSessionWrapper

createDurableSubscriber

public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
                                                         java.lang.String name)
                                                  throws javax.jms.JMSException

Overrides:

createDurableSubscriber in class AbstractSessionWrapper

createDurableSubscriber

public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
                                                         java.lang.String name,
                                                         java.lang.String messageSelector,
                                                         boolean noLocal)
                                                  throws javax.jms.JMSException

Overrides:

createDurableSubscriber in class AbstractSessionWrapper

preMessageProcess

public boolean preMessageProcess()
                          throws javax.jms.JMSException

Specified by:

preMessageProcess in interface SessionWrapper

Overrides:

preMessageProcess in class JRunXASessionImpl

postMessageProcess

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

Specified by:

postMessageProcess in interface SessionWrapper

Overrides:

postMessageProcess in class JRunXASessionImpl