Package com.webmethods.jms.loadbalance.connection

Class WmClusterTopicSessionImpl

java.lang.Object

com.webmethods.locks.Node

com.webmethods.jms.impl.WmSessionImpl

com.webmethods.jms.loadbalance.connection.WmClusterSessionImpl

com.webmethods.jms.loadbalance.connection.WmClusterTopicSessionImpl

All Implemented Interfaces:

WmSession, java.lang.Runnable, javax.jms.Session, javax.jms.TopicSession

public class WmClusterTopicSessionImpl
extends WmClusterSessionImpl
implements javax.jms.TopicSession

Nested Class Summary

Nested classes/interfaces inherited from class com.webmethods.jms.impl.WmSessionImpl

WmSessionImpl.SessionDispatcher

Field Summary

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

activeSubSessions, COMMITED, COMMITING, conn, currentBrokerURL, map, policy, PREPARED, PREPARING, random, sharedQueue, sharedReadWriteLock, subSessions, TENTATIVE

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

_acknowledgeMode, _closed, _closeInProgress, _connection, _currentAsyncMessage, _isXA, _logApi, _messageConsumers, _messageListener, _messageProducers, _messageQueue, _newMessageListeners, _sessionDispatcher, _sessionDispatcherCount, _sessionReconnect, _sessionSubscriberMessageConsumers, _transacted, _transactionID, _transactionTimeout, _xid, brokerName, DEFAULT_TRANSACTION_TIMEOUT

Fields inherited from class com.webmethods.locks.Node

_lockManager

Fields inherited from interface javax.jms.Session

AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	WmClusterTopicSessionImpl(WmClusterConnectionImpl connection, boolean transacted, boolean isXA, int acknowledgeMode)

Method Summary

Modifier and Type	Method	Description
javax.jms.QueueBrowser	createBrowser(javax.jms.Queue queue)	Thows an IllegalStateException.
javax.jms.QueueBrowser	createBrowser(javax.jms.Queue queue, java.lang.String messageSelector)	Thows an IllegalStateException.
javax.jms.Queue	createQueue(java.lang.String queueName)	Thows an IllegalStateException.
javax.jms.TemporaryQueue	createTemporaryQueue()	Thows an IllegalStateException.

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

addMessageConsumer, addMessageToQueue, addSessionSubscriberMessageConsumer, addToSubSessions, checkCreateDurableConsumer, checkState, clearOnTransactionComplete, close, commit, createConsumer, createConsumer, createConsumer, createDurableSubscriber, createDurableSubscriber, createQueueBrowserImpl, createReceiver, createReceiver, createSubscriber, createSubscriber, createSubSession, createTemporaryQueue, createTemporaryTopic, createTemporaryTopic, createTopic, getBrokerSessionIfActive, getCurrentBrokerURL, getMessageListener, getNextBrokerToPublish, getRemainingBrokersToPublish, getSubSessions, getTransacted, initMultiSendBestEffortSeeder, isXA, logActiveClusterSessions, publish, publish, publishToWorker, recover, removeMessageConsumer, removeSessionSubscriberMessageConsumer, rollback, run, selectPrimaryWithRotation, sessionAcknowledge, sessionAcknowledge, setCurrentBrokerURL, setMessageListener, setMessageQueue, start, stop, toString, unsubscribe, unsubscribe

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

addMessageProducer, checkCreateConsumer, checkCreateProducer, checkForClusteringSupport, closeMessageConsumers, closeMessageProducers, createBytesMessage, createFileMessage, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createPublisher, createSender, createStreamMessage, createTextMessage, createTextMessage, get_messageQueue, get_transactionID, getAcknowledgeMode, getBrokerName, getConnection, getDurableSubscriber, getExceptionListener, getMessageConsumers, getSessionDispatcherThreadID, getTemporaryQueueName, getTemporaryTopicName, invokeExceptionListener, isTransacted, prepare, prepare, recoverInternal, removeMessageProducer, sessionAcknowledgeInternal, setCurrentAsynMessage, setExceptionListener, setMessageListener, validAcknowledgeMode

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.Session

close, commit, createBytesMessage, createConsumer, createConsumer, createConsumer, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createStreamMessage, createTextMessage, createTextMessage, getAcknowledgeMode, getMessageListener, getTransacted, recover, rollback, run, setMessageListener

Methods inherited from interface javax.jms.TopicSession

createDurableSubscriber, createDurableSubscriber, createPublisher, createSubscriber, createSubscriber, createTemporaryTopic, createTopic, unsubscribe

Constructor Detail

WmClusterTopicSessionImpl

protected WmClusterTopicSessionImpl(WmClusterConnectionImpl connection,
                                    boolean transacted,
                                    boolean isXA,
                                    int acknowledgeMode)
                             throws javax.jms.JMSException

Throws:

javax.jms.JMSException

Method Detail

createQueue

public javax.jms.Queue createQueue(java.lang.String queueName)
                            throws javax.jms.JMSException

Thows an IllegalStateException.

Specified by:

createQueue in interface javax.jms.Session

Overrides:

createQueue in class WmClusterSessionImpl

Parameters:

queueName - the name of this Queue

Returns:

a Queue with the given name

Throws:

javax.jms.JMSException - if the session fails to create a queue due to some internal error.

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue)
                                     throws javax.jms.JMSException

Thows an IllegalStateException.

Specified by:

createBrowser in interface javax.jms.Session

Overrides:

createBrowser in class WmClusterSessionImpl

Parameters:

queue - the queue to access

Throws:

javax.jms.JMSException - if the session fails to create a browser due to some internal error.

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

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue,
                                            java.lang.String messageSelector)
                                     throws javax.jms.JMSException

Thows an IllegalStateException.

Specified by:

createBrowser in interface javax.jms.Session

Overrides:

createBrowser in class WmClusterSessionImpl

Parameters:

queue - the queue to access

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.

Throws:

javax.jms.JMSException - if the session fails to create a browser due to some internal error.

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

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

createTemporaryQueue

public javax.jms.TemporaryQueue createTemporaryQueue()
                                              throws javax.jms.JMSException

Thows an IllegalStateException.

Specified by:

createTemporaryQueue in interface javax.jms.Session

Overrides:

createTemporaryQueue in class WmClusterSessionImpl

Returns:

a temporary queue identity

Throws:

javax.jms.JMSException - if the session fails to create a temporary queue due to some internal error.