org.objectweb.joram.client.connector

Class OutboundTopicSession

Implemented Interfaces:
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

Method Summary

javax.jms.QueueBrowser
createBrowser(javax.jms.Queue queue)
API method.
javax.jms.QueueBrowser
createBrowser(javax.jms.Queue queue, String selector)
API method.
javax.jms.TopicPublisher
createPublisher(Topic topic)
Delegates the call to the wrapped JMS session.
javax.jms.Queue
createQueue(String queueName)
API method.
TopicSubscriber
createSubscriber(Topic topic)
Delegates the call to the wrapped JMS session.
TopicSubscriber
createSubscriber(Topic topic, String selector)
Delegates the call to the wrapped JMS session.
TopicSubscriber
createSubscriber(Topic topic, 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, createBrowser, createBrowser, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createQueue, createStreamMessage, createTemporaryQueue, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, getAcknowledgeMode, getMessageListener, getTransacted, isStarted, recover, rollback, run, setMessageListener, unsubscribe

Method Details

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue)
            throws JMSException
API method.
Overrides:
createBrowser in interface OutboundSession


createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue,
                                            String selector)
            throws JMSException
API method.
Overrides:
createBrowser in interface OutboundSession


createPublisher

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


createQueue

public javax.jms.Queue createQueue(String queueName)
            throws JMSException
API method.
Overrides:
createQueue in interface OutboundSession


createSubscriber

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


createSubscriber

public TopicSubscriber createSubscriber(Topic topic,
                                        String selector)
            throws JMSException
Delegates the call to the wrapped JMS session.


createSubscriber

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


createTemporaryQueue

public javax.jms.TemporaryQueue createTemporaryQueue()
            throws JMSException
API method.
Overrides:
createTemporaryQueue in interface OutboundSession


Copyright B) 2004 Scalagent - All rights reserved