jrun.jms.wrapper.enterprise
Class AbstractConnectionWrapper

jrun.jms.wrapper.enterprise.AbstractConnectionWrapper

All Implemented Interfaces:

ConnectionWrapper, StateObject

Direct Known Subclasses:

JRunXAConnectionImpl

public abstract class AbstractConnectionWrapper

implements ConnectionWrapper

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

AbstractConnectionWrapper()

Method Summary

void	addSession(SessionWrapper sw)
void	cleanUpSessions()
void	close()
javax.jms.ConnectionConsumer	createConnectionConsumer(javax.jms.Queue queue, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages)
javax.jms.ConnectionConsumer	createConnectionConsumer(javax.jms.Topic topic, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages)
javax.jms.ConnectionConsumer	createDurableConnectionConsumer(javax.jms.Topic topic, java.lang.String subscriptionName, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages)
java.lang.String	getClientID()
int	getConnectionStatus()
javax.jms.Connection	getDelegate()
javax.jms.ExceptionListener	getExceptionListener()
int	getInvokerType()
javax.jms.ConnectionMetaData	getMetaData()
boolean	getUsePTPDomain()
javax.jms.XAConnection	getXADelegate()
boolean	hasSessionInTransaction()
void	removeSession(SessionWrapper sw)
void	setClientID(java.lang.String clientID)
void	setConnectionStatus(int status)
void	setDelegate(javax.jms.Connection connection)
void	setExceptionListener(javax.jms.ExceptionListener listener)
void	setInvokerType(int type)
void	setUsePTPDomain(boolean useFlag)
void	start()
void	stop()
boolean	transactionInProgress()

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

isTransacted

Constructor Detail

AbstractConnectionWrapper

public AbstractConnectionWrapper()

Method Detail

setInvokerType

public void setInvokerType(int type)

getInvokerType

public int getInvokerType()

addSession

public void addSession(SessionWrapper sw)

removeSession

public void removeSession(SessionWrapper sw)

close

public void close()
           throws javax.jms.JMSException

cleanUpSessions

public void cleanUpSessions()
                     throws javax.jms.JMSException

getConnectionStatus

public int getConnectionStatus()

setConnectionStatus

public void setConnectionStatus(int status)

getUsePTPDomain

public boolean getUsePTPDomain()

setUsePTPDomain

public void setUsePTPDomain(boolean useFlag)

setDelegate

public void setDelegate(javax.jms.Connection connection)

Specified by:

setDelegate in interface ConnectionWrapper

getDelegate

public javax.jms.Connection getDelegate()

Specified by:

getDelegate in interface ConnectionWrapper

getXADelegate

public javax.jms.XAConnection getXADelegate()

Specified by:

getXADelegate in interface ConnectionWrapper

getClientID

public java.lang.String getClientID()
                             throws javax.jms.JMSException

setClientID

public void setClientID(java.lang.String clientID)
                 throws javax.jms.JMSException

getMetaData

public javax.jms.ConnectionMetaData getMetaData()
                                         throws javax.jms.JMSException

getExceptionListener

public javax.jms.ExceptionListener getExceptionListener()
                                                 throws javax.jms.JMSException

setExceptionListener

public void setExceptionListener(javax.jms.ExceptionListener listener)
                          throws javax.jms.JMSException

start

public void start()
           throws javax.jms.JMSException

stop

public void stop()
          throws javax.jms.JMSException

createConnectionConsumer

public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Queue queue,
                                                             java.lang.String messageSelector,
                                                             javax.jms.ServerSessionPool sessionPool,
                                                             int maxMessages)
                                                      throws javax.jms.JMSException

createConnectionConsumer

public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Topic topic,
                                                             java.lang.String messageSelector,
                                                             javax.jms.ServerSessionPool sessionPool,
                                                             int maxMessages)
                                                      throws javax.jms.JMSException

createDurableConnectionConsumer

public javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic topic,
                                                                    java.lang.String subscriptionName,
                                                                    java.lang.String messageSelector,
                                                                    javax.jms.ServerSessionPool sessionPool,
                                                                    int maxMessages)
                                                             throws javax.jms.JMSException

transactionInProgress

public boolean transactionInProgress()

hasSessionInTransaction

public boolean hasSessionInTransaction()