Package com.webmethods.jms.loadbalance.connection

Class WmClusterQueueConnectionImpl

java.lang.Object

com.webmethods.locks.Node

com.webmethods.jms.impl.WmConnectionImpl

com.webmethods.jms.loadbalance.connection.WmClusterConnectionImpl

com.webmethods.jms.loadbalance.connection.WmClusterQueueConnectionImpl

All Implemented Interfaces:

WmClusterTrackable, WmConnection, WmQueueConnection, javax.jms.Connection, javax.jms.QueueConnection

Direct Known Subclasses:

WmClusterXAQueueConnectionImpl

public class WmClusterQueueConnectionImpl
extends WmClusterConnectionImpl
implements WmQueueConnection

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
WmClusterQueueConnectionImpl(WmConnectionFactoryImpl factory, java.lang.String userName, java.lang.String password, boolean isXA)	Protected constructor.
WmClusterQueueConnectionImpl(WmConnectionFactoryImpl factory, java.lang.String userName, java.lang.String password, java.lang.String accessLabelHint, boolean isXA)

Method Summary

Modifier and Type	Method	Description
javax.jms.ConnectionConsumer	createDurableConnectionConsumer(javax.jms.Topic topic, java.lang.String subscriptionName, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages)	Thows an IllegalStateException.

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

canPublish, close, close1PCLog, createConnectionConsumer, createConnectionConsumer, createConnectionConsumer, 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.QueueConnection

createConnectionConsumer, createQueueSession

Methods inherited from interface com.webmethods.jms.WmConnection

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

Constructor Detail

WmClusterQueueConnectionImpl

public WmClusterQueueConnectionImpl(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

WmClusterQueueConnectionImpl

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

Throws:

javax.jms.JMSException

Method Detail

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

Thows an IllegalStateException.

Specified by:

createDurableConnectionConsumer in interface javax.jms.Connection

Overrides:

createDurableConnectionConsumer in class WmClusterConnectionImpl

Parameters:

topic - topic to access

subscriptionName - durable subscription name

messageSelector - only messages with properties matching the message selector expression are delivered. A value of null or an empty string indicates that there is no message selector for the message consumer.

sessionPool - the server session pool to associate with this durable connection consumer

maxMessages - the maximum number of messages that can be assigned to a server session at one time

Returns:

the durable connection consumer

Throws:

javax.jms.JMSException - if the Connection object fails to create a connection consumer due to some internal error or invalid arguments for sessionPool and messageSelector.

javax.jms.InvalidDestinationException - if an invalid destination is specified.

javax.jms.InvalidSelectorException - if the message selector is invalid.