Package com.webmethods.jms.loadbalance.connection

Class WmClusterConnectionWorker

java.lang.Object

com.webmethods.locks.Node

com.webmethods.jms.impl.WmConnectionImpl

com.webmethods.jms.loadbalance.connection.WmClusterConnectionWorker

All Implemented Interfaces:

WmConnection, java.lang.Runnable, javax.jms.Connection

public class WmClusterConnectionWorker
extends WmConnectionImpl
implements java.lang.Runnable

Field Summary

Fields inherited from class com.webmethods.jms.impl.WmConnectionImpl

_accessLabelHint, _brokerURLs, _clientID, _closeClusterConnection, _closed, _closeInProgress, _exceptionListener, _exceptionListenerCalledOnce, _factory, _isXA, _isXACloseCalled, _logApi, _password, _protocolHandler, _sessions, _setClientIDProhibited, _started, _uniqueID, _username, AUTO_RECONNECT, connectionStatus, isSSLEnabled, NO_RECONNECT, RECONNECT

Fields inherited from class com.webmethods.locks.Node

_lockManager

Fields inherited from interface com.webmethods.jms.WmConnection

ENCRYPT_LEVEL_ENCRYPTION, ENCRYPT_LEVEL_NO_ENCRYPTION, ENCRYPT_LEVEL_US_DOMESTIC, ENCRYPT_LEVEL_US_EXPORT

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	WmClusterConnectionWorker(WmConnectionFactoryImpl factory, java.lang.String username, java.lang.String password, java.lang.String accessLabelHint, java.lang.String brokerURL)

Method Summary

Modifier and Type	Method	Description
protected void	closeConnection()
java.lang.String	getBrokerURL()
void	run()

Methods inherited from class com.webmethods.jms.impl.WmConnectionImpl

acknowledgeModeToString, addConnectionConsumer, addSession, addTemporaryDestination, canPublish, checkLocalQueue, checkState, close, closeSessions, commit, commit, containsTemporaryDestination, createConnectionConsumer, createConnectionConsumer, createConnectionConsumer, createDurableConnectionConsumer, createQueueSession, createSession, createTopicSession, createXAQueueSession, createXASession, createXATopicSession, endTransaction, forget, getAccessLabel, getBroker, getBrokerName, getClientID, getClientIDUnsafe, getConnectionStatus, getDurableSubscriber, getExceptionListener, getFactory, getMarshalIn, getMarshalInUserData, getMarshalOut, getMarshalOutUserData, getMessageFactory, getMetaData, getNotificationListener, getPublishProcessState, getSSLEncryptionLevel, getSSLServerCertificate, getTemporaryDestinations, getTerritory, getUniqueID, getUserName, initConnection, initializeConnection, initializeReceiver, initializeSubscriber, initKeepAliveThread, invokeExceptionListener, invokeNotificationListener, isClosed, isSSLEnabled, isStarted, isTransactionCompleted, markForClosure, ping, prepare, prepare, publish, publish, publish, publish, recover, removeConnectionConsumer, removeSession, removeTemporaryDestination, rollback, rollback, sendKeepAliveResponse, setClientID, setConnectionStatus, setExceptionListener, setNotificationListener, setParentConnection, setSSLEnabled, start, startSessions, startTransaction, startTransaction, startTransaction, stop, stopSessions, toString, unsubscribeDurableSubscriber

Methods inherited from class com.webmethods.locks.Node

getLockManager, getParent

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

WmClusterConnectionWorker

protected WmClusterConnectionWorker(WmConnectionFactoryImpl factory,
                                    java.lang.String username,
                                    java.lang.String password,
                                    java.lang.String accessLabelHint,
                                    java.lang.String brokerURL)
                             throws javax.jms.JMSException

Throws:

javax.jms.JMSException

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

closeConnection

protected void closeConnection()
                        throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getBrokerURL

public java.lang.String getBrokerURL()