jrun.jms.wrapper.enterprise
Class AbstractSessionWrapper

jrun.jms.wrapper.enterprise.AbstractSessionWrapper

All Implemented Interfaces:

SessionWrapper, StateObject

Direct Known Subclasses:

JRunXASessionImpl

public abstract class AbstractSessionWrapper

implements SessionWrapper

Field Summary

static int	AUTO_COMMIT_FALSE
static int	AUTO_COMMIT_TRUE
static int	DT_PROCESSING
static int	INITIAL
protected boolean	m_startMsgProcess
static int	STATUS_MESSAGE_PROCESSING
static int	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

AbstractSessionWrapper()

Method Summary

void	autoCommit()
void	autoRollback()
void	close()
void	commit()
javax.jms.QueueBrowser	createBrowser(javax.jms.Queue queue)
javax.jms.QueueBrowser	createBrowser(javax.jms.Queue queue, java.lang.String messageSelector)
javax.jms.BytesMessage	createBytesMessage()
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.MapMessage	createMapMessage()
javax.jms.Message	createMessage()
javax.jms.ObjectMessage	createObjectMessage()
javax.jms.ObjectMessage	createObjectMessage(java.io.Serializable object)
javax.jms.TopicPublisher	createPublisher(javax.jms.Topic topic)
javax.jms.Queue	createQueue(java.lang.String queueName)
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.StreamMessage	createStreamMessage()
javax.jms.TopicSubscriber	createSubscriber(javax.jms.Topic topic)
javax.jms.TopicSubscriber	createSubscriber(javax.jms.Topic topic, java.lang.String messageSelector, boolean noLocal)
javax.jms.TemporaryQueue	createTemporaryQueue()
javax.jms.TemporaryTopic	createTemporaryTopic()
javax.jms.TextMessage	createTextMessage()
javax.jms.TextMessage	createTextMessage(java.lang.String text)
javax.jms.Topic	createTopic(java.lang.String topicName)
int	getInvokerType()
javax.jms.MessageListener	getMessageListener()
javax.jms.QueueSession	getQueueSession()
int	getSessionStatus()
javax.jms.TopicSession	getTopicSession()
boolean	getTransacted()
boolean	getTransactionInProgress()
boolean	handleTransaction(javax.transaction.Transaction tx)
boolean	isAutoCommit()
boolean	isClosed()
boolean	isRestricted()
void	markClosed()
void	recover()
void	rollback()
void	run()
void	SetInitialTransactionAttributes(boolean transacted, int mode)
void	setInvokerType(int type)
void	setMessageListener(javax.jms.MessageListener listener)
void	setSessionStatus(int status)
void	setTransactionInProgress(boolean status)
boolean	TransactioninProgress()
void	unsubscribe(java.lang.String name)

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

getDelegate, getXADelegate, getXAResource, postMessageProcess, preMessageProcess, sameTransaction, setConnectionWrapper, setDelegate

Field Detail

AUTO_COMMIT_FALSE

public static final int AUTO_COMMIT_FALSE

AUTO_COMMIT_TRUE

public static final int AUTO_COMMIT_TRUE

DT_PROCESSING

public static final int DT_PROCESSING

INITIAL

public static final int INITIAL

STATUS_MESSAGE_PROCESSING

public static final int STATUS_MESSAGE_PROCESSING

STATUS_READY_FOR_MESSAGE_PROCESSING

public static final int STATUS_READY_FOR_MESSAGE_PROCESSING

m_startMsgProcess

protected boolean m_startMsgProcess

Constructor Detail

AbstractSessionWrapper

public AbstractSessionWrapper()

Method Detail

isAutoCommit

public boolean isAutoCommit()

SetInitialTransactionAttributes

public void SetInitialTransactionAttributes(boolean transacted,
                                            int mode)
                                     throws javax.jms.JMSException

Specified by:

SetInitialTransactionAttributes in interface SessionWrapper

handleTransaction

public boolean handleTransaction(javax.transaction.Transaction tx)
                          throws javax.jms.JMSException

setSessionStatus

public void setSessionStatus(int status)

getSessionStatus

public int getSessionStatus()

markClosed

public void markClosed()

close

public void close()
           throws javax.jms.JMSException

Specified by:

close in interface SessionWrapper

isClosed

public boolean isClosed()

getInvokerType

public int getInvokerType()

setInvokerType

public void setInvokerType(int type)

getTransactionInProgress

public boolean getTransactionInProgress()

setTransactionInProgress

public void setTransactionInProgress(boolean status)

isRestricted

public boolean isRestricted()

TransactioninProgress

public boolean TransactioninProgress()

Specified by:

TransactioninProgress in interface SessionWrapper

createBytesMessage

public javax.jms.BytesMessage createBytesMessage()
                                          throws javax.jms.JMSException

createMapMessage

public javax.jms.MapMessage createMapMessage()
                                      throws javax.jms.JMSException

createMessage

public javax.jms.Message createMessage()
                                throws javax.jms.JMSException

createObjectMessage

public javax.jms.ObjectMessage createObjectMessage()
                                            throws javax.jms.JMSException

createObjectMessage

public javax.jms.ObjectMessage createObjectMessage(java.io.Serializable object)
                                            throws javax.jms.JMSException

createStreamMessage

public javax.jms.StreamMessage createStreamMessage()
                                            throws javax.jms.JMSException

createTextMessage

public javax.jms.TextMessage createTextMessage()
                                        throws javax.jms.JMSException

createTextMessage

public javax.jms.TextMessage createTextMessage(java.lang.String text)
                                        throws javax.jms.JMSException

getTransacted

public boolean getTransacted()
                      throws javax.jms.JMSException

autoRollback

public void autoRollback()
                  throws javax.jms.JMSException

autoCommit

public void autoCommit()
                throws javax.jms.JMSException

commit

public void commit()
            throws javax.jms.JMSException

rollback

public void rollback()
              throws javax.jms.JMSException

recover

public void recover()
             throws javax.jms.JMSException

getMessageListener

public javax.jms.MessageListener getMessageListener()
                                             throws javax.jms.JMSException

setMessageListener

public void setMessageListener(javax.jms.MessageListener listener)
                        throws javax.jms.JMSException

run

public void run()

createQueue

public javax.jms.Queue createQueue(java.lang.String queueName)
                            throws javax.jms.JMSException

createSender

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

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue)
                                     throws javax.jms.JMSException

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue,
                                            java.lang.String messageSelector)
                                     throws javax.jms.JMSException

createTemporaryQueue

public javax.jms.TemporaryQueue createTemporaryQueue()
                                              throws javax.jms.JMSException

createTopic

public javax.jms.Topic createTopic(java.lang.String topicName)
                            throws javax.jms.JMSException

createPublisher

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

createTemporaryTopic

public javax.jms.TemporaryTopic createTemporaryTopic()
                                              throws javax.jms.JMSException

unsubscribe

public void unsubscribe(java.lang.String name)
                 throws javax.jms.JMSException

createReceiver

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

createReceiver

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

createSubscriber

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

createSubscriber

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

createDurableSubscriber

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

createDurableSubscriber

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

getQueueSession

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

getTopicSession

public javax.jms.TopicSession getTopicSession()
                                       throws javax.jms.JMSException