Joram ${version}

org.objectweb.joram.client.connector
Class OutboundTopicSession

java.lang.Object
  extended byorg.objectweb.joram.client.connector.OutboundSession
      extended byorg.objectweb.joram.client.connector.OutboundTopicSession
All Implemented Interfaces:
java.lang.Runnable, javax.jms.Session, javax.jms.TopicSession

public class OutboundTopicSession
extends OutboundSession
implements javax.jms.TopicSession

An OutboundTopicSession instance wraps a JMS TopicSession (XA or not) for a component involved in PubSub outbound messaging.


Field Summary
 
Fields inherited from class org.objectweb.joram.client.connector.OutboundSession
cnx, transacted
 
Fields inherited from interface javax.jms.Session
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
 
Method Summary
 javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue)
          API method.
 javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue, java.lang.String selector)
          API method.
 javax.jms.TopicPublisher createPublisher(javax.jms.Topic topic)
          Delegates the call to the wrapped JMS session.
 javax.jms.Queue createQueue(java.lang.String queueName)
          API method.
 javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic)
          Delegates the call to the wrapped JMS session.
 javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic, java.lang.String selector)
          Delegates the call to the wrapped JMS session.
 javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic, java.lang.String selector, boolean noLocal)
          Delegates the call to the wrapped JMS session.
 javax.jms.TemporaryQueue createTemporaryQueue()
          API method.
 
Methods inherited from class org.objectweb.joram.client.connector.OutboundSession
close, commit, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createStreamMessage, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, getAcknowledgeMode, getMessageListener, getTransacted, isStarted, recover, rollback, run, setMessageListener, unsubscribe
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface javax.jms.TopicSession
createDurableSubscriber, createDurableSubscriber, createTemporaryTopic, createTopic, unsubscribe
 
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
 

Method Detail

createPublisher

public javax.jms.TopicPublisher createPublisher(javax.jms.Topic topic)
                                         throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
createPublisher in interface javax.jms.TopicSession
Throws:
javax.jms.JMSException

createSubscriber

public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic,
                                                  java.lang.String selector,
                                                  boolean noLocal)
                                           throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

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 selector)
                                           throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Throws:
javax.jms.JMSException

createSubscriber

public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic)
                                           throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
createSubscriber in interface javax.jms.TopicSession
Throws:
javax.jms.JMSException

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue,
                                            java.lang.String selector)
                                     throws javax.jms.JMSException
API method.

Specified by:
createBrowser in interface javax.jms.Session
Overrides:
createBrowser in class OutboundSession
Throws:
javax.jms.IllegalStateException - Systematically.
javax.jms.JMSException

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue)
                                     throws javax.jms.JMSException
API method.

Specified by:
createBrowser in interface javax.jms.Session
Overrides:
createBrowser in class OutboundSession
Throws:
javax.jms.IllegalStateException - Systematically.
javax.jms.JMSException

createQueue

public javax.jms.Queue createQueue(java.lang.String queueName)
                            throws javax.jms.JMSException
API method.

Specified by:
createQueue in interface javax.jms.Session
Overrides:
createQueue in class OutboundSession
Throws:
javax.jms.IllegalStateException - Systematically.
javax.jms.JMSException

createTemporaryQueue

public javax.jms.TemporaryQueue createTemporaryQueue()
                                              throws javax.jms.JMSException
API method.

Specified by:
createTemporaryQueue in interface javax.jms.Session
Overrides:
createTemporaryQueue in class OutboundSession
Throws:
javax.jms.IllegalStateException - Systematically.
javax.jms.JMSException

Joram ${version}

Copyright © 2005 Scalagent - All rights reserved