jrun.jms.xa
Class JRunXAConnectionImpl

jrun.jms.wrapper.enterprise.AbstractConnectionWrapper
  |
  +--jrun.jms.xa.JRunXAConnectionImpl

All Implemented Interfaces:

ConnectionWrapper, JRunXAConnection, StateObject

Direct Known Subclasses:

JRunXAConnectionWrapper

public class JRunXAConnectionImpl

extends AbstractConnectionWrapper

implements JRunXAConnection

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

InvalidOperation

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

STATUS_CLOSED, STATUS_MARKED_CLOSED, STATUS_STARTED, STATUS_STOPPED, STATUS_UNDEFINED, STATUS_WAIT

Constructor Summary

JRunXAConnectionImpl()

JRunXAConnectionImpl(javax.jms.Connection connection)

Method Summary

void	close()
javax.jms.QueueSession	createQueueSession(boolean transacted, int acknowledgeMode)
javax.jms.TopicSession	createTopicSession(boolean transacted, int acknowledgeMode)
javax.jms.XAQueueSession	createXAQueueSession()
javax.jms.XATopicSession	createXATopicSession()
javax.jms.QueueSession	initXAQueueSession()
javax.jms.TopicSession	initXATopicSession()
boolean	isTransacted()
void	onSessionClose(javax.jms.XASession session)
void	setDelegate(javax.jms.Connection connection)

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

addSession, cleanUpSessions, createConnectionConsumer, createConnectionConsumer, createDurableConnectionConsumer, getClientID, getConnectionStatus, getDelegate, getExceptionListener, getInvokerType, getMetaData, getUsePTPDomain, getXADelegate, hasSessionInTransaction, removeSession, setClientID, setConnectionStatus, setExceptionListener, setInvokerType, setUsePTPDomain, start, stop, transactionInProgress

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

getDelegate, getXADelegate

Constructor Detail

JRunXAConnectionImpl

public JRunXAConnectionImpl(javax.jms.Connection connection)

JRunXAConnectionImpl

public JRunXAConnectionImpl()

Method Detail

isTransacted

public boolean isTransacted()

Specified by:

isTransacted in interface ConnectionWrapper

setDelegate

public void setDelegate(javax.jms.Connection connection)

Specified by:

setDelegate in interface ConnectionWrapper

Overrides:

setDelegate in class AbstractConnectionWrapper

close

public void close()
           throws javax.jms.JMSException

Overrides:

close in class AbstractConnectionWrapper

onSessionClose

public void onSessionClose(javax.jms.XASession session)
                    throws javax.jms.JMSException

Specified by:

onSessionClose in interface JRunXAConnection

createQueueSession

public javax.jms.QueueSession createQueueSession(boolean transacted,
                                                 int acknowledgeMode)
                                          throws javax.jms.JMSException

initXAQueueSession

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

createXAQueueSession

public javax.jms.XAQueueSession createXAQueueSession()
                                              throws javax.jms.JMSException

createTopicSession

public javax.jms.TopicSession createTopicSession(boolean transacted,
                                                 int acknowledgeMode)
                                          throws javax.jms.JMSException

initXATopicSession

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

createXATopicSession

public javax.jms.XATopicSession createXATopicSession()
                                              throws javax.jms.JMSException