Package com.webmethods.jms.impl

Class WmTopicSessionImpl

java.lang.Object

com.webmethods.locks.Node

com.webmethods.jms.impl.WmSessionImpl

com.webmethods.jms.impl.WmTopicSessionImpl

All Implemented Interfaces:

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

public class WmTopicSessionImpl
extends WmSessionImpl
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.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	WmTopicSessionImpl(WmConnectionImpl 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.impl.WmSessionImpl

addMessageConsumer, addMessageProducer, addMessageToQueue, addSessionSubscriberMessageConsumer, checkCreateConsumer, checkCreateDurableConsumer, checkCreateProducer, checkForClusteringSupport, checkState, close, closeMessageConsumers, closeMessageProducers, commit, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableSubscriber, createDurableSubscriber, createFileMessage, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createPublisher, createQueueBrowserImpl, createReceiver, createReceiver, createSender, createStreamMessage, createSubscriber, createSubscriber, createTemporaryQueue, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, get_messageQueue, get_transactionID, getAcknowledgeMode, getBrokerName, getConnection, getDurableSubscriber, getExceptionListener, getMessageConsumers, getMessageListener, getSessionDispatcherThreadID, getTemporaryQueueName, getTemporaryTopicName, getTransacted, invokeExceptionListener, isTransacted, prepare, prepare, publish, publish, recover, recoverInternal, removeMessageConsumer, removeMessageProducer, removeSessionSubscriberMessageConsumer, rollback, run, sessionAcknowledge, sessionAcknowledgeInternal, setCurrentAsynMessage, setExceptionListener, setMessageListener, setMessageListener, setMessageQueue, start, stop, toString, unsubscribe, unsubscribe, 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

WmTopicSessionImpl

protected WmTopicSessionImpl(WmConnectionImpl 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 WmSessionImpl

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 WmSessionImpl

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 WmSessionImpl

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 WmSessionImpl

Returns:

a temporary queue identity

Throws:

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