Package com.webmethods.jms.impl

Class WmXATopicSessionImpl

java.lang.Object

com.webmethods.locks.Node

com.webmethods.jms.impl.WmSessionImpl

com.webmethods.jms.impl.WmXASessionImpl

com.webmethods.jms.impl.WmXATopicSessionImpl

All Implemented Interfaces:

WmSession, java.lang.Runnable, javax.jms.Session, javax.jms.TopicSession, javax.jms.XASession, javax.jms.XATopicSession, javax.transaction.xa.XAResource

public class WmXATopicSessionImpl
extends WmXASessionImpl
implements javax.jms.TopicSession, javax.jms.XATopicSession

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.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.
javax.jms.TopicSession	getTopicSession()	Gets the topic session associated with this XATopicSession.

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, 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, invokeExceptionListener, isTransacted, prepare, prepare, publish, publish, recover, recoverInternal, removeMessageConsumer, removeMessageProducer, removeSessionSubscriberMessageConsumer, 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, createBytesMessage, createConsumer, createConsumer, createConsumer, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createStreamMessage, createTextMessage, createTextMessage, getAcknowledgeMode, getMessageListener, recover, run, setMessageListener

Methods inherited from interface javax.jms.TopicSession

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

Methods inherited from interface javax.jms.XASession

commit, getSession, getTransacted, getXAResource, rollback

Method Detail

getTopicSession

public javax.jms.TopicSession getTopicSession()
                                       throws javax.jms.JMSException

Gets the topic session associated with this XATopicSession.

Specified by:

getTopicSession in interface javax.jms.XATopicSession

Returns:

the topic session object

Throws:

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

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.