Package com.webmethods.jms.impl

Class WmQueueSessionImpl

java.lang.Object

com.webmethods.locks.Node

com.webmethods.jms.impl.WmSessionImpl

com.webmethods.jms.impl.WmQueueSessionImpl

All Implemented Interfaces:

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

public class WmQueueSessionImpl
extends WmSessionImpl
implements javax.jms.QueueSession

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	WmQueueSessionImpl(WmConnectionImpl connection, boolean transacted, boolean isXA, int acknowledgeMode)

Method Summary

Modifier and Type	Method	Description
javax.jms.TopicSubscriber	createDurableSubscriber(javax.jms.Topic topic, java.lang.String name)	Thows an IllegalStateException.
javax.jms.TopicSubscriber	createDurableSubscriber(javax.jms.Topic topic, java.lang.String name, java.lang.String messageSelector, boolean noLocal)	Thows an IllegalStateException.
javax.jms.TemporaryTopic	createTemporaryTopic()	Thows an IllegalStateException.
javax.jms.Topic	createTopic(java.lang.String topicName)	Thows an IllegalStateException.
void	unsubscribe(java.lang.String name)	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, createBrowser, createBrowser, createBytesMessage, createConsumer, createConsumer, createConsumer, createFileMessage, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createPublisher, createQueue, createQueueBrowserImpl, createReceiver, createReceiver, createSender, createStreamMessage, createSubscriber, createSubscriber, createTemporaryQueue, createTemporaryQueue, createTextMessage, createTextMessage, 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, 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.QueueSession

createBrowser, createBrowser, createQueue, createReceiver, createReceiver, createSender, createTemporaryQueue

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

Constructor Detail

WmQueueSessionImpl

protected WmQueueSessionImpl(WmConnectionImpl connection,
                             boolean transacted,
                             boolean isXA,
                             int acknowledgeMode)
                      throws javax.jms.JMSException

Throws:

javax.jms.JMSException

Method Detail

createDurableSubscriber

public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
                                                         java.lang.String name)
                                                  throws javax.jms.JMSException

Thows an IllegalStateException.

Specified by:

createDurableSubscriber in interface javax.jms.Session

Overrides:

createDurableSubscriber in class WmSessionImpl

Parameters:

topic - the non-temporary Topic to subscribe to

name - the name used to identify this subscription

Throws:

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

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

createDurableSubscriber

public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
                                                         java.lang.String name,
                                                         java.lang.String messageSelector,
                                                         boolean noLocal)
                                                  throws javax.jms.JMSException

Thows an IllegalStateException.

Specified by:

createDurableSubscriber in interface javax.jms.Session

Overrides:

createDurableSubscriber in class WmSessionImpl

Parameters:

topic - the non-temporary Topic to subscribe to

name - the name used to identify this subscription

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.

noLocal - if set, inhibits the delivery of messages published by its own connection

Throws:

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

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

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

createTemporaryTopic

public javax.jms.TemporaryTopic createTemporaryTopic()
                                              throws javax.jms.JMSException

Thows an IllegalStateException.

Specified by:

createTemporaryTopic in interface javax.jms.Session

Overrides:

createTemporaryTopic in class WmSessionImpl

Returns:

a temporary topic identity

Throws:

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

createTopic

public javax.jms.Topic createTopic(java.lang.String topicName)
                            throws javax.jms.JMSException

Thows an IllegalStateException.

Specified by:

createTopic in interface javax.jms.Session

Overrides:

createTopic in class WmSessionImpl

Parameters:

topicName - the name of this Topic

Returns:

a Topic with the given name

Throws:

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

unsubscribe

public void unsubscribe(java.lang.String name)
                 throws javax.jms.JMSException

Thows an IllegalStateException.

Specified by:

unsubscribe in interface javax.jms.Session

Overrides:

unsubscribe in class WmSessionImpl

Parameters:

name - the name used to identify this subscription

Throws:

javax.jms.JMSException - if the session fails to unsubscribe to the durable subscription due to some internal error.

javax.jms.InvalidDestinationException - if an invalid subscription name is specified.