Joram ${version}

org.objectweb.joram.client.connector
Class OutboundSession

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

public class OutboundSession
extends java.lang.Object
implements javax.jms.Session

An OutboundSession instance wraps a JMS session (XA or not) for a component involved in outbound messaging.


Field Summary
protected  OutboundConnection cnx
          The OutboundConnection the session belongs to.
protected  boolean transacted
           
 
Fields inherited from interface javax.jms.Session
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
 
Method Summary
 void close()
          Actually does nothing, closing of the session occurs while closing the component's connection.
 void commit()
          Forbidden call on a component's outbound session, throws a IllegalStateException instance.
 javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue)
          Delegates the call to the wrapped JMS session.
 javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue, java.lang.String selector)
          Delegates the call to the wrapped JMS session.
 javax.jms.BytesMessage createBytesMessage()
          Delegates the call to the wrapped JMS session.
 javax.jms.MessageConsumer createConsumer(javax.jms.Destination dest)
          Delegates the call to the wrapped JMS session.
 javax.jms.MessageConsumer createConsumer(javax.jms.Destination dest, java.lang.String selector)
          Delegates the call to the wrapped JMS session.
 javax.jms.MessageConsumer createConsumer(javax.jms.Destination dest, java.lang.String selector, boolean noLocal)
          Delegates the call to the wrapped JMS session.
 javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic, java.lang.String name)
          Delegates the call to the wrapped JMS session.
 javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic, java.lang.String name, java.lang.String selector, boolean noLocal)
          Delegates the call to the wrapped JMS session.
 javax.jms.MapMessage createMapMessage()
          Delegates the call to the wrapped JMS session.
 javax.jms.Message createMessage()
          Delegates the call to the wrapped JMS session.
 javax.jms.ObjectMessage createObjectMessage()
          Delegates the call to the wrapped JMS session.
 javax.jms.ObjectMessage createObjectMessage(java.io.Serializable obj)
          Delegates the call to the wrapped JMS session.
 javax.jms.MessageProducer createProducer(javax.jms.Destination dest)
          Delegates the call to the wrapped JMS session.
 javax.jms.Queue createQueue(java.lang.String queueName)
          Delegates the call to the wrapped JMS session.
 javax.jms.StreamMessage createStreamMessage()
          Delegates the call to the wrapped JMS session.
 javax.jms.TemporaryQueue createTemporaryQueue()
          Delegates the call to the wrapped JMS session.
 javax.jms.TemporaryTopic createTemporaryTopic()
          Delegates the call to the wrapped JMS session.
 javax.jms.TextMessage createTextMessage()
          Delegates the call to the wrapped JMS session.
 javax.jms.TextMessage createTextMessage(java.lang.String text)
          Delegates the call to the wrapped JMS session.
 javax.jms.Topic createTopic(java.lang.String topicName)
          Delegates the call to the wrapped JMS session.
 int getAcknowledgeMode()
          Delegates the call to the wrapped JMS session.
 javax.jms.MessageListener getMessageListener()
          Forbidden call on a component's outbound session, throws a IllegalStateException instance.
 boolean getTransacted()
          Delegates the call to the wrapped JMS session.
 boolean isStarted()
          return started value.
 void recover()
          Delegates the call to the wrapped JMS session.
 void rollback()
          Forbidden call on a component's outbound session, throws a IllegalStateException instance.
 void run()
          Method never used by a component, does nothing.
 void setMessageListener(javax.jms.MessageListener messageListener)
          Forbidden call on a component's outbound session, throws a IllegalStateException instance.
 void unsubscribe(java.lang.String name)
          Delegates the call to the wrapped JMS session.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

cnx

protected OutboundConnection cnx
The OutboundConnection the session belongs to.


transacted

protected boolean transacted
Method Detail

getAcknowledgeMode

public int getAcknowledgeMode()
                       throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
getAcknowledgeMode in interface javax.jms.Session
Throws:
javax.jms.JMSException

getTransacted

public boolean getTransacted()
                      throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
getTransacted in interface javax.jms.Session
Throws:
javax.jms.JMSException

setMessageListener

public void setMessageListener(javax.jms.MessageListener messageListener)
                        throws javax.jms.JMSException
Forbidden call on a component's outbound session, throws a IllegalStateException instance.

Specified by:
setMessageListener in interface javax.jms.Session
Throws:
javax.jms.JMSException

getMessageListener

public javax.jms.MessageListener getMessageListener()
                                             throws javax.jms.JMSException
Forbidden call on a component's outbound session, throws a IllegalStateException instance.

Specified by:
getMessageListener in interface javax.jms.Session
Throws:
javax.jms.JMSException

createMessage

public javax.jms.Message createMessage()
                                throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
createMessage in interface javax.jms.Session
Throws:
javax.jms.JMSException

createTextMessage

public javax.jms.TextMessage createTextMessage()
                                        throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
createTextMessage in interface javax.jms.Session
Throws:
javax.jms.JMSException

createTextMessage

public javax.jms.TextMessage createTextMessage(java.lang.String text)
                                        throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
createTextMessage in interface javax.jms.Session
Throws:
javax.jms.JMSException

createBytesMessage

public javax.jms.BytesMessage createBytesMessage()
                                          throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
createBytesMessage in interface javax.jms.Session
Throws:
javax.jms.JMSException

createMapMessage

public javax.jms.MapMessage createMapMessage()
                                      throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
createMapMessage in interface javax.jms.Session
Throws:
javax.jms.JMSException

createObjectMessage

public javax.jms.ObjectMessage createObjectMessage()
                                            throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
createObjectMessage in interface javax.jms.Session
Throws:
javax.jms.JMSException

createObjectMessage

public javax.jms.ObjectMessage createObjectMessage(java.io.Serializable obj)
                                            throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
createObjectMessage in interface javax.jms.Session
Throws:
javax.jms.JMSException

createStreamMessage

public javax.jms.StreamMessage createStreamMessage()
                                            throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
createStreamMessage in interface javax.jms.Session
Throws:
javax.jms.JMSException

createBrowser

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

Specified by:
createBrowser in interface javax.jms.Session
Throws:
javax.jms.JMSException

createBrowser

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

Specified by:
createBrowser in interface javax.jms.Session
Throws:
javax.jms.JMSException

createProducer

public javax.jms.MessageProducer createProducer(javax.jms.Destination dest)
                                         throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
createProducer in interface javax.jms.Session
Throws:
javax.jms.JMSException

createConsumer

public javax.jms.MessageConsumer createConsumer(javax.jms.Destination dest,
                                                java.lang.String selector,
                                                boolean noLocal)
                                         throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
createConsumer in interface javax.jms.Session
Throws:
javax.jms.JMSException

createConsumer

public javax.jms.MessageConsumer createConsumer(javax.jms.Destination dest,
                                                java.lang.String selector)
                                         throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
createConsumer in interface javax.jms.Session
Throws:
javax.jms.JMSException

createConsumer

public javax.jms.MessageConsumer createConsumer(javax.jms.Destination dest)
                                         throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
createConsumer in interface javax.jms.Session
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
Delegates the call to the wrapped JMS session.

Specified by:
createDurableSubscriber in interface javax.jms.Session
Throws:
javax.jms.JMSException

createDurableSubscriber

public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
                                                         java.lang.String name)
                                                  throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
createDurableSubscriber in interface javax.jms.Session
Throws:
javax.jms.JMSException

createQueue

public javax.jms.Queue createQueue(java.lang.String queueName)
                            throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
createQueue in interface javax.jms.Session
Throws:
javax.jms.JMSException

createTopic

public javax.jms.Topic createTopic(java.lang.String topicName)
                            throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
createTopic in interface javax.jms.Session
Throws:
javax.jms.JMSException

createTemporaryQueue

public javax.jms.TemporaryQueue createTemporaryQueue()
                                              throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
createTemporaryQueue in interface javax.jms.Session
Throws:
javax.jms.JMSException

createTemporaryTopic

public javax.jms.TemporaryTopic createTemporaryTopic()
                                              throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
createTemporaryTopic in interface javax.jms.Session
Throws:
javax.jms.JMSException

run

public void run()
Method never used by a component, does nothing.

Specified by:
run in interface javax.jms.Session

commit

public void commit()
            throws javax.jms.JMSException
Forbidden call on a component's outbound session, throws a IllegalStateException instance.

Specified by:
commit in interface javax.jms.Session
Throws:
javax.jms.JMSException

rollback

public void rollback()
              throws javax.jms.JMSException
Forbidden call on a component's outbound session, throws a IllegalStateException instance.

Specified by:
rollback in interface javax.jms.Session
Throws:
javax.jms.JMSException

recover

public void recover()
             throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
recover in interface javax.jms.Session
Throws:
javax.jms.JMSException

unsubscribe

public void unsubscribe(java.lang.String name)
                 throws javax.jms.JMSException
Delegates the call to the wrapped JMS session.

Specified by:
unsubscribe in interface javax.jms.Session
Throws:
javax.jms.JMSException

close

public void close()
           throws javax.jms.JMSException
Actually does nothing, closing of the session occurs while closing the component's connection.

Specified by:
close in interface javax.jms.Session
Throws:
javax.jms.JMSException

isStarted

public boolean isStarted()
return started value.


Joram ${version}

Copyright ? 2005 Scalagent - All rights reserved