org.objectweb.jonas_jms
Class JTopicSession

java.lang.Object
  org.objectweb.jonas_jms.JSession
      org.objectweb.jonas_jms.JTopicSession

All Implemented Interfaces:

java.lang.Runnable, javax.jms.Session, javax.jms.TopicSession, javax.transaction.Synchronization

public class JTopicSession
extends JSession
implements javax.jms.TopicSession

Author:

Laurent Chauvirey, Frederic Maistre, Nicolas Tachker Contributor(s): Philippe Durieux Philippe Coq

Field Summary

protected javax.jms.TopicSession	ts
protected javax.jms.XATopicConnection	xatc
protected javax.jms.XATopicSession	xats

Fields inherited from class org.objectweb.jonas_jms.JSession

closed, currtx, jconn, sess, tm, txover, xac, xares, xasess

Fields inherited from interface javax.jms.Session

AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED

Constructor Summary

JTopicSession(JConnection jconn, javax.jms.XATopicConnection xatc)
Constructor

Method Summary

javax.jms.TopicSubscriber	createDurableSubscriber(javax.jms.Topic topic, java.lang.String name)
javax.jms.TopicSubscriber	createDurableSubscriber(javax.jms.Topic topic, java.lang.String name, java.lang.String messageSelector, boolean noLocal)
javax.jms.TopicPublisher	createPublisher(javax.jms.Topic topic)
javax.jms.TopicSubscriber	createSubscriber(javax.jms.Topic topic)
javax.jms.TopicSubscriber	createSubscriber(javax.jms.Topic topic, java.lang.String messageSelector, boolean noLocal)
javax.jms.TemporaryTopic	createTemporaryTopic()
javax.jms.Topic	createTopic(java.lang.String topicName)
protected javax.jms.Session	getMOMSession() Get the underlaying MOM Session.
protected javax.jms.TopicSession	getMOMTopicSession()
protected void	MOMSessionClose()
void	unsubscribe(java.lang.String name)

Methods inherited from class org.objectweb.jonas_jms.JSession

afterCompletion, beforeCompletion, close, commit, createBrowser, createBrowser, createBytesMessage, createConsumer, createConsumer, createConsumer, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createQueue, createStreamMessage, createTemporaryQueue, createTextMessage, createTextMessage, getAcknowledgeMode, getMessageListener, getTransacted, getXAResource, PhysicalClose, recover, rollback, run, setMessageListener

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface javax.jms.Session

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

Field Detail

xatc

protected javax.jms.XATopicConnection xatc

ts

protected javax.jms.TopicSession ts

xats

protected javax.jms.XATopicSession xats

Constructor Detail

JTopicSession

public JTopicSession(JConnection jconn,
                     javax.jms.XATopicConnection xatc)

Constructor

Method Detail

getMOMSession

protected javax.jms.Session getMOMSession()
                                   throws javax.jms.JMSException

Get the underlaying MOM Session.

Overrides:

getMOMSession in class JSession

Returns:

- session

Throws:

javax.jms.JMSException

getMOMTopicSession

protected javax.jms.TopicSession getMOMTopicSession()
                                             throws javax.jms.JMSException

Throws:

javax.jms.JMSException

MOMSessionClose

protected void MOMSessionClose()

Overrides:

MOMSessionClose in class JSession

createTopic

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

Specified by:

createTopic in interface javax.jms.Session

Specified by:

createTopic in interface javax.jms.TopicSession

Overrides:

createTopic in class JSession

Throws:

javax.jms.JMSException

createSubscriber

public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic)
                                           throws javax.jms.JMSException

Specified by:

createSubscriber in interface javax.jms.TopicSession

Throws:

javax.jms.JMSException

createSubscriber

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

Specified by:

createSubscriber in interface javax.jms.TopicSession

Throws:

javax.jms.JMSException

createDurableSubscriber

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

Specified by:

createDurableSubscriber in interface javax.jms.Session

Specified by:

createDurableSubscriber in interface javax.jms.TopicSession

Overrides:

createDurableSubscriber in class JSession

Throws:

javax.jms.JMSException

createDurableSubscriber

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

Specified by:

createDurableSubscriber in interface javax.jms.Session

Specified by:

createDurableSubscriber in interface javax.jms.TopicSession

Overrides:

createDurableSubscriber in class JSession

Throws:

javax.jms.JMSException

createPublisher

public javax.jms.TopicPublisher createPublisher(javax.jms.Topic topic)
                                         throws javax.jms.JMSException

Specified by:

createPublisher in interface javax.jms.TopicSession

Throws:

javax.jms.JMSException

createTemporaryTopic

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

Specified by:

createTemporaryTopic in interface javax.jms.Session

Specified by:

createTemporaryTopic in interface javax.jms.TopicSession

Overrides:

createTemporaryTopic in class JSession

Throws:

javax.jms.JMSException

unsubscribe

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

Specified by:

unsubscribe in interface javax.jms.Session

Specified by:

unsubscribe in interface javax.jms.TopicSession

Overrides:

unsubscribe in class JSession

Throws:

javax.jms.JMSException

javax.jms.InvalidDestinationException