org.objectweb.joram.client.connector
Class OutboundSession

java.lang.Object
  org.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.