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.xa.XAResource

public class JTopicSession
extends JSession
implements javax.jms.TopicSession


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, tm, txover, xares
 
Fields inherited from interface javax.jms.Session
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE
 
Fields inherited from interface javax.transaction.xa.XAResource
TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY
 
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
close, commit, commit, createBytesMessage, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createStreamMessage, createTextMessage, createTextMessage, end, forget, getMessageListener, getTransacted, getTransactionTimeout, isSameRM, PhysicalClose, prepare, recover, recover, rollback, rollback, run, setMessageListener, setTransactionTimeout, start
 
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, createBytesMessage, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createStreamMessage, createTextMessage, createTextMessage, 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

getMOMTopicSession

protected javax.jms.TopicSession getMOMTopicSession()
                                             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.TopicSession

createSubscriber

public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic)
                                           throws javax.jms.JMSException
Specified by:
createSubscriber in interface javax.jms.TopicSession

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

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

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

createPublisher

public javax.jms.TopicPublisher createPublisher(javax.jms.Topic topic)
                                         throws javax.jms.JMSException
Specified by:
createPublisher in interface javax.jms.TopicSession

createTemporaryTopic

public javax.jms.TemporaryTopic createTemporaryTopic()
                                              throws javax.jms.JMSException
Specified by:
createTemporaryTopic in interface javax.jms.TopicSession

unsubscribe

public void unsubscribe(java.lang.String name)
                 throws javax.jms.JMSException,
                        javax.jms.InvalidDestinationException
Specified by:
unsubscribe in interface javax.jms.TopicSession