org.objectweb.joram.client.connector
Class OutboundQueueSession

java.lang.Object
  extended byorg.objectweb.joram.client.connector.OutboundSession
      extended byorg.objectweb.joram.client.connector.OutboundQueueSession
All Implemented Interfaces:
javax.jms.QueueSession, java.lang.Runnable, 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
 
Fields inherited from interface javax.jms.Session
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
 
Method Summary
 javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic, java.lang.String name)
          API method.
 javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic, java.lang.String name, java.lang.String selector, boolean noLocal)
          API method.
 javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue)
          Delegates the call to the wrapped JMS session.
 javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue, java.lang.String selector)
          Delegates the call to the wrapped JMS session.
 javax.jms.QueueSender createSender(javax.jms.Queue queue)
          Delegates the call to the wrapped JMS session.
 javax.jms.TemporaryTopic createTemporaryTopic()
          API method.
 javax.jms.Topic createTopic(java.lang.String topicName)
          API method.
 java.lang.String toString()
           
 void unsubscribe(java.lang.String name)
          API method.
 
Methods inherited from class org.objectweb.joram.client.connector.OutboundSession
close, commit, createBrowser, createBrowser, createBytesMessage, createConsumer, createConsumer, createConsumer, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createQueue, createStreamMessage, createTemporaryQueue, createTextMessage, createTextMessage, getAcknowledgeMode, getMessageListener, getTransacted, isStarted, recover, rollback, run, setMessageListener
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface javax.jms.QueueSession
createBrowser, createBrowser, createQueue, createTemporaryQueue
 
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

createSender

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

Specified by:
createSender in interface javax.jms.QueueSession
Throws:
javax.jms.JMSException

createReceiver

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

Specified by:
createReceiver in interface javax.jms.QueueSession
Throws:
javax.jms.JMSException

createReceiver

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

Specified by:
createReceiver in interface javax.jms.QueueSession
Throws:
javax.jms.JMSException

createDurableSubscriber

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

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

createDurableSubscriber

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

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

createTopic

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

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

createTemporaryTopic

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

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

unsubscribe

public void unsubscribe(java.lang.String name)
                 throws javax.jms.JMSException
API method.

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

toString

public java.lang.String toString()


Copyright ? 2004 Scalagent - All rights reserved