org.objectweb.joram.client.connector

Class OutboundQueueSession

Implemented Interfaces:
javax.jms.QueueSession, javax.jms.Session

public class OutboundQueueSession
extends OutboundSession
implements javax.jms.QueueSession

An OutboundQueueSession instance wraps a JMS QueueSession (XA or not) for a component involved in PTP outbound messaging.

Field Summary

Fields inherited from class org.objectweb.joram.client.connector.OutboundSession

cnx, transacted

Method Summary

javax.jms.TopicSubscriber
createDurableSubscriber(javax.jms.Topic topic, String name)
API method.
javax.jms.TopicSubscriber
createDurableSubscriber(javax.jms.Topic topic, String name, String selector, boolean noLocal)
API method.
javax.jms.QueueReceiver
createReceiver(Queue queue)
Delegates the call to the wrapped JMS session.
javax.jms.QueueReceiver
createReceiver(Queue queue, String selector)
Delegates the call to the wrapped JMS session.
javax.jms.QueueSender
createSender(Queue queue)
Delegates the call to the wrapped JMS session.
javax.jms.TemporaryTopic
createTemporaryTopic()
API method.
javax.jms.Topic
createTopic(String topicName)
API method.
String
toString()
void
unsubscribe(String name)
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

createDurableSubscriber

public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
                                                         String name)
            throws JMSException
API method.
Overrides:
createDurableSubscriber in interface OutboundSession


createDurableSubscriber

public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
                                                         String name,
                                                         String selector,
                                                         boolean noLocal)
            throws JMSException
API method.
Overrides:
createDurableSubscriber in interface OutboundSession


createReceiver

public javax.jms.QueueReceiver createReceiver(Queue queue)
            throws JMSException
Delegates the call to the wrapped JMS session.


createReceiver

public javax.jms.QueueReceiver createReceiver(Queue queue,
                                              String selector)
            throws JMSException
Delegates the call to the wrapped JMS session.


createSender

public javax.jms.QueueSender createSender(Queue queue)
            throws JMSException
Delegates the call to the wrapped JMS session.


createTemporaryTopic

public javax.jms.TemporaryTopic createTemporaryTopic()
            throws JMSException
API method.
Overrides:
createTemporaryTopic in interface OutboundSession


createTopic

public javax.jms.Topic createTopic(String topicName)
            throws JMSException
API method.
Overrides:
createTopic in interface OutboundSession


toString

public String toString()


unsubscribe

public void unsubscribe(String name)
            throws JMSException
API method.
Overrides:
unsubscribe in interface OutboundSession


Copyright B) 2004 Scalagent - All rights reserved