org.objectweb.joram.client.connector

Class OutboundSession

Implemented Interfaces:
javax.jms.Session
Known Direct 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

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, 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, String selector)
Delegates the call to the wrapped JMS session.
javax.jms.MessageConsumer
createConsumer(javax.jms.Destination dest, String selector, boolean noLocal)
Delegates the call to the wrapped JMS session.
javax.jms.TopicSubscriber
createDurableSubscriber(javax.jms.Topic topic, String name)
Delegates the call to the wrapped JMS session.
javax.jms.TopicSubscriber
createDurableSubscriber(javax.jms.Topic topic, String name, 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(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(String text)
Delegates the call to the wrapped JMS session.
javax.jms.Topic
createTopic(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(String name)
Delegates the call to the wrapped JMS session.

Field Details

cnx

protected OutboundConnection cnx
The OutboundConnection the session belongs to.


transacted

protected boolean transacted

Method Details

close

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


commit

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


createBrowser

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


createBrowser

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


createBytesMessage

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


createConsumer

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


createConsumer

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


createConsumer

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


createDurableSubscriber

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


createDurableSubscriber

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


createMapMessage

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


createMessage

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


createObjectMessage

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


createObjectMessage

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


createProducer

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


createQueue

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


createStreamMessage

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


createTemporaryQueue

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


createTemporaryTopic

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


createTextMessage

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


createTextMessage

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


createTopic

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


getAcknowledgeMode

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


getMessageListener

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


getTransacted

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


isStarted

public boolean isStarted()
return started value.


recover

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


rollback

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


run

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


setMessageListener

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


unsubscribe

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


Copyright B) 2004 Scalagent - All rights reserved