Package com.webmethods.jms.impl

Class WmQueueConnectionImpl

java.lang.Object

com.webmethods.locks.Node

com.webmethods.jms.impl.WmConnectionImpl

com.webmethods.jms.impl.WmQueueConnectionImpl

All Implemented Interfaces:

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

Direct Known Subclasses:

WmXAQueueConnectionImpl

public class WmQueueConnectionImpl
extends WmConnectionImpl
implements WmQueueConnection

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

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.impl.WmConnectionImpl

acknowledgeModeToString, addConnectionConsumer, addSession, addTemporaryDestination, canPublish, checkLocalQueue, checkState, close, closeSessions, commit, commit, containsTemporaryDestination, createConnectionConsumer, createConnectionConsumer, createConnectionConsumer, 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

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

WmQueueConnectionImpl

protected WmQueueConnectionImpl(WmConnectionFactoryImpl factory,
                                java.lang.String userName,
                                java.lang.String password)
                         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

WmQueueConnectionImpl

protected WmQueueConnectionImpl(WmConnectionFactoryImpl factory,
                                java.lang.String userName,
                                java.lang.String password,
                                java.lang.String accessLabelHint)
                         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 WmConnectionImpl

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.