Package com.webmethods.jms.loadbalance.connection

Class WmClusterTopicConnectionImpl

java.lang.Object

com.webmethods.locks.Node

com.webmethods.jms.impl.WmConnectionImpl

com.webmethods.jms.loadbalance.connection.WmClusterConnectionImpl

com.webmethods.jms.loadbalance.connection.WmClusterTopicConnectionImpl

All Implemented Interfaces:

WmClusterTrackable, WmConnection, WmTopicConnection, javax.jms.Connection, javax.jms.TopicConnection

Direct Known Subclasses:

WmClusterXATopicConnectionImpl

public class WmClusterTopicConnectionImpl
extends WmClusterConnectionImpl
implements WmTopicConnection

Field Summary

Fields inherited from class com.webmethods.jms.loadbalance.connection.WmClusterConnectionImpl

connections, DATE_FORMAT_NOW, policy

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

Constructor	Description
WmClusterTopicConnectionImpl(WmConnectionFactoryImpl factory, java.lang.String userName, java.lang.String password, boolean isXA)	Protected constructor.
WmClusterTopicConnectionImpl(WmConnectionFactoryImpl factory, java.lang.String userName, java.lang.String password, java.lang.String accessLabelHint, boolean isXA)

Method Summary

Methods inherited from class com.webmethods.jms.loadbalance.connection.WmClusterConnectionImpl

canPublish, close, close1PCLog, createConnectionConsumer, createConnectionConsumer, createConnectionConsumer, createDurableConnectionConsumer, createQueueSession, createSession, createTopicSession, createWeightedRRList, createXAQueueSession, createXAQueueSession, createXASession, createXASession, createXATopicSession, createXATopicSession, getAllBrokersInCluster, getBroker, getBrokerCluster, getClusterConnectionId, getConnectionFactory, getConnectionList, getCurrentBrokerIndex, getExceptionListener, getMetaData, getMultiSendBEIndex, getMultiSendBESeeder, getNextBrokerToPublish, getNextWorker, getNotificationListener, getPolicy, getPublishProcessState, getWeightedMap, getWeigthRRBrokers, getWorker, getWriter, invokeExceptionListener, markForClosure, open1PCLog, ping, removeSession, setClientID, setClusterConnectionId, setExceptionListener, setMultiSendBEIndex, setMultiSendBESeeder, setNotificationListener, setParentConnection, setTracker, setTrackerCategories, start, stop, write1PCLog

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

acknowledgeModeToString, addConnectionConsumer, addSession, addTemporaryDestination, checkLocalQueue, checkState, closeSessions, commit, commit, containsTemporaryDestination, endTransaction, forget, getAccessLabel, getBrokerName, getClientID, getClientIDUnsafe, getConnectionStatus, getDurableSubscriber, getFactory, getMarshalIn, getMarshalInUserData, getMarshalOut, getMarshalOutUserData, getMessageFactory, getSSLEncryptionLevel, getSSLServerCertificate, getTemporaryDestinations, getTerritory, getUniqueID, getUserName, initConnection, initializeConnection, initializeReceiver, initializeSubscriber, initKeepAliveThread, invokeNotificationListener, isClosed, isSSLEnabled, isStarted, isTransactionCompleted, prepare, prepare, publish, publish, publish, publish, recover, removeConnectionConsumer, removeTemporaryDestination, rollback, rollback, sendKeepAliveResponse, setConnectionStatus, setParentConnection, setSSLEnabled, startSessions, startTransaction, startTransaction, startTransaction, 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

Methods inherited from interface javax.jms.Connection

close, createConnectionConsumer, createSession, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop

Methods inherited from interface javax.jms.TopicConnection

createConnectionConsumer, createDurableConnectionConsumer, createTopicSession

Methods inherited from interface com.webmethods.jms.WmConnection

getAccessLabel, getBroker, getFactory, getSSLEncryptionLevel, getSSLServerCertificate, getTerritory, ping

Constructor Detail

WmClusterTopicConnectionImpl

public WmClusterTopicConnectionImpl(WmConnectionFactoryImpl factory,
                                    java.lang.String userName,
                                    java.lang.String password,
                                    boolean isXA)
                             throws javax.jms.JMSException

Protected constructor.

Parameters:

factory - the factory that created this connection

userName - the caller's user name

password - the caller's password

Throws:

javax.jms.JMSException

WmClusterTopicConnectionImpl

public WmClusterTopicConnectionImpl(WmConnectionFactoryImpl factory,
                                    java.lang.String userName,
                                    java.lang.String password,
                                    java.lang.String accessLabelHint,
                                    boolean isXA)
                             throws javax.jms.JMSException

Throws:

javax.jms.JMSException