org.objectweb.joram.client.connector
Class OutboundQueueSession

java.lang.Object
  org.objectweb.joram.client.connector.OutboundSession
      org.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()