Package com.webmethods.jms.impl

Class WmXAQueueSessionImpl

java.lang.Object

com.webmethods.locks.Node

com.webmethods.jms.impl.WmSessionImpl

com.webmethods.jms.impl.WmXASessionImpl

com.webmethods.jms.impl.WmXAQueueSessionImpl

All Implemented Interfaces:

WmSession, java.lang.Runnable, javax.jms.QueueSession, javax.jms.Session, javax.jms.XAQueueSession, javax.jms.XASession, javax.transaction.xa.XAResource

public class WmXAQueueSessionImpl
extends WmXASessionImpl
implements javax.jms.QueueSession, javax.jms.XAQueueSession

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

_transactionComplete

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

Fields inherited from interface javax.transaction.xa.XAResource

TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY

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.
javax.jms.QueueSession	getQueueSession()	Gets the queue session associated with this XAQueueSession.
void	unsubscribe(java.lang.String name)	Thows an IllegalStateException.

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

commit, commit, createXASession, end, forget, getSession, getTransacted, getTransactionTimeout, getXAResource, isSameRM, isTransactionComplete, negativeAckMessageQueue, prepare, recover, rollback, rollback, setTransactionTimeout, start

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

addMessageConsumer, addMessageProducer, addMessageToQueue, addSessionSubscriberMessageConsumer, checkCreateConsumer, checkCreateDurableConsumer, checkCreateProducer, checkForClusteringSupport, checkState, close, closeMessageConsumers, closeMessageProducers, 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, invokeExceptionListener, isTransacted, prepare, prepare, publish, publish, recover, recoverInternal, removeMessageConsumer, removeMessageProducer, removeSessionSubscriberMessageConsumer, 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, createBytesMessage, createConsumer, createConsumer, createConsumer, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createStreamMessage, createTextMessage, createTextMessage, getAcknowledgeMode, getMessageListener, recover, run, setMessageListener

Methods inherited from interface javax.jms.XASession

commit, getSession, getTransacted, getXAResource, rollback

Method Detail

getQueueSession

public javax.jms.QueueSession getQueueSession()
                                       throws javax.jms.JMSException

Gets the queue session associated with this XAQueueSession.

Specified by:

getQueueSession in interface javax.jms.XAQueueSession

Returns:

the queue session object

Throws:

javax.jms.JMSException - if an internal error occurs.

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.