Package org.objectweb.joram.client.connector

Class OutboundSession

java.lang.Object

org.objectweb.joram.client.connector.OutboundSession

All Implemented Interfaces:

AutoCloseable, Runnable, Session

Direct Known Subclasses:

OutboundQueueSession, OutboundTopicSession

public class OutboundSession
extends Object
implements Session

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

Field Summary

Fields

Modifier and Type	Field	Description
protected OutboundConnection	cnx	The OutboundConnection the session belongs to.
private static boolean	DEBUG
private static Logger	logger
(package private) Session	sess	The wrapped JMS session.
(package private) boolean	started	true if the session is started.
protected boolean	transacted
(package private) boolean	valid	true if this "handle" is valid.

Fields inherited from interface javax.jms.Session

AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED

Constructor Summary

Constructors

Constructor	Description
OutboundSession(Session sess, OutboundConnection cnx)	Constructs an OutboundSession instance.
OutboundSession(Session sess, OutboundConnection cnx, boolean transacted)	Constructs an OutboundSession instance.

Method Summary

Modifier and Type	Method	Description
(package private) void	checkValidity()	Checks the validity of the session.
void	close()	In Java EE, 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.
QueueBrowser	createBrowser(Queue queue)	Delegates the call to the wrapped JMS session.
QueueBrowser	createBrowser(Queue queue, String selector)	Delegates the call to the wrapped JMS session.
BytesMessage	createBytesMessage()	Delegates the call to the wrapped JMS session.
MessageConsumer	createConsumer(Destination dest)	Delegates the call to the wrapped JMS session.
MessageConsumer	createConsumer(Destination dest, String selector)	Delegates the call to the wrapped JMS session.
MessageConsumer	createConsumer(Destination dest, String selector, boolean noLocal)	Delegates the call to the wrapped JMS session.
MessageConsumer	createDurableConsumer(Topic topic, String name)	Delegates the call to the wrapped JMS session.
MessageConsumer	createDurableConsumer(Topic topic, String name, String messageSelector, boolean noLocal)	Delegates the call to the wrapped JMS session.
TopicSubscriber	createDurableSubscriber(Topic topic, String name)	Delegates the call to the wrapped JMS session.
TopicSubscriber	createDurableSubscriber(Topic topic, String name, String selector, boolean noLocal)	Delegates the call to the wrapped JMS session.
MapMessage	createMapMessage()	Delegates the call to the wrapped JMS session.
Message	createMessage()	Delegates the call to the wrapped JMS session.
ObjectMessage	createObjectMessage()	Delegates the call to the wrapped JMS session.
ObjectMessage	createObjectMessage(Serializable obj)	Delegates the call to the wrapped JMS session.
MessageProducer	createProducer(Destination dest)	Delegates the call to the wrapped JMS session.
Queue	createQueue(String queueName)	Delegates the call to the wrapped JMS session.
MessageConsumer	createSharedConsumer(Topic topic, String sharedSubscriptionName)	Delegates the call to the wrapped JMS session.
MessageConsumer	createSharedConsumer(Topic topic, String sharedSubscriptionName, String messageSelector)
MessageConsumer	createSharedDurableConsumer(Topic topic, String name)	Delegates the call to the wrapped JMS session.
MessageConsumer	createSharedDurableConsumer(Topic topic, String name, String messageSelector)	Delegates the call to the wrapped JMS session.
StreamMessage	createStreamMessage()	Delegates the call to the wrapped JMS session.
TemporaryQueue	createTemporaryQueue()	Delegates the call to the wrapped JMS session.
TemporaryTopic	createTemporaryTopic()	Delegates the call to the wrapped JMS session.
TextMessage	createTextMessage()	Delegates the call to the wrapped JMS session.
TextMessage	createTextMessage(String text)	Delegates the call to the wrapped JMS session.
Topic	createTopic(String topicName)	Delegates the call to the wrapped JMS session.
int	getAcknowledgeMode()	Delegates the call to the wrapped JMS session.
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(MessageListener messageListener)	Forbidden call on a component's outbound session, throws a IllegalStateException instance.
(package private) void	start()	set started = true
String	toString()
void	unsubscribe(String name)	Delegates the call to the wrapped JMS session.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

logger

private static final Logger logger

DEBUG

private static final boolean DEBUG

cnx

protected OutboundConnection cnx

The OutboundConnection the session belongs to.

sess

Session sess

The wrapped JMS session.

valid

boolean valid

true if this "handle" is valid.

started

boolean started

true if the session is started.

transacted

protected boolean transacted

Constructor Detail

OutboundSession

OutboundSession(Session sess,
                OutboundConnection cnx)

Constructs an OutboundSession instance.

OutboundSession

OutboundSession(Session sess,
                OutboundConnection cnx,
                boolean transacted)

Constructs an OutboundSession instance.

Method Detail

isStarted

public boolean isStarted()

return started value.

start

void start()

set started = true

checkValidity

void checkValidity()
            throws IllegalStateException

Checks the validity of the session.

Throws:

IllegalStateException

toString

public String toString()

Overrides:

toString in class Object

getAcknowledgeMode

public int getAcknowledgeMode()
                       throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

getAcknowledgeMode in interface Session

Throws:

JMSException

getTransacted

public boolean getTransacted()
                      throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

getTransacted in interface Session

Throws:

JMSException

setMessageListener

public void setMessageListener(MessageListener messageListener)
                        throws JMSException

Forbidden call on a component's outbound session, throws a IllegalStateException instance.

Specified by:

setMessageListener in interface Session

Throws:

JMSException

getMessageListener

public MessageListener getMessageListener()
                                   throws JMSException

Forbidden call on a component's outbound session, throws a IllegalStateException instance.

Specified by:

getMessageListener in interface Session

Throws:

JMSException

createMessage

public Message createMessage()
                      throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createMessage in interface Session

Throws:

JMSException

createTextMessage

public TextMessage createTextMessage()
                              throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createTextMessage in interface Session

Throws:

JMSException

createTextMessage

public TextMessage createTextMessage(String text)
                              throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createTextMessage in interface Session

Throws:

JMSException

createBytesMessage

public BytesMessage createBytesMessage()
                                throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createBytesMessage in interface Session

Throws:

JMSException

createMapMessage

public MapMessage createMapMessage()
                            throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createMapMessage in interface Session

Throws:

JMSException

createObjectMessage

public ObjectMessage createObjectMessage()
                                  throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createObjectMessage in interface Session

Throws:

JMSException

createObjectMessage

public ObjectMessage createObjectMessage(Serializable obj)
                                  throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createObjectMessage in interface Session

Throws:

JMSException

createStreamMessage

public StreamMessage createStreamMessage()
                                  throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createStreamMessage in interface Session

Throws:

JMSException

createBrowser

public QueueBrowser createBrowser(Queue queue,
                                  String selector)
                           throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createBrowser in interface Session

Throws:

JMSException

createBrowser

public QueueBrowser createBrowser(Queue queue)
                           throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createBrowser in interface Session

Throws:

JMSException

createProducer

public MessageProducer createProducer(Destination dest)
                               throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createProducer in interface Session

Throws:

JMSException

createConsumer

public MessageConsumer createConsumer(Destination dest,
                                      String selector,
                                      boolean noLocal)
                               throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createConsumer in interface Session

Throws:

JMSException

createConsumer

public MessageConsumer createConsumer(Destination dest,
                                      String selector)
                               throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createConsumer in interface Session

Throws:

JMSException

createConsumer

public MessageConsumer createConsumer(Destination dest)
                               throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createConsumer in interface Session

Throws:

JMSException

createDurableSubscriber

public TopicSubscriber createDurableSubscriber(Topic topic,
                                               String name,
                                               String selector,
                                               boolean noLocal)
                                        throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createDurableSubscriber in interface Session

Throws:

JMSException

createDurableSubscriber

public TopicSubscriber createDurableSubscriber(Topic topic,
                                               String name)
                                        throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createDurableSubscriber in interface Session

Throws:

JMSException

createQueue

public Queue createQueue(String queueName)
                  throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createQueue in interface Session

Throws:

JMSException

createTopic

public Topic createTopic(String topicName)
                  throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createTopic in interface Session

Throws:

JMSException

createTemporaryQueue

public TemporaryQueue createTemporaryQueue()
                                    throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createTemporaryQueue in interface Session

Throws:

JMSException

createTemporaryTopic

public TemporaryTopic createTemporaryTopic()
                                    throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createTemporaryTopic in interface Session

Throws:

JMSException

run

public void run()

Method never used by a component, does nothing.

Specified by:

run in interface Runnable

Specified by:

run in interface Session

commit

public void commit()
            throws JMSException

Forbidden call on a component's outbound session, throws a IllegalStateException instance.

Specified by:

commit in interface Session

Throws:

JMSException

rollback

public void rollback()
              throws JMSException

Forbidden call on a component's outbound session, throws a IllegalStateException instance.

Specified by:

rollback in interface Session

Throws:

JMSException

recover

public void recover()
             throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

recover in interface Session

Throws:

JMSException

unsubscribe

public void unsubscribe(String name)
                 throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

unsubscribe in interface Session

Throws:

JMSException

close

public void close()
           throws JMSException

In Java EE, closing of the session occurs while closing the component's connection.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Session

Throws:

JMSException

createSharedConsumer

public MessageConsumer createSharedConsumer(Topic topic,
                                            String sharedSubscriptionName)
                                     throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createSharedConsumer in interface Session

Throws:

JMSException

createSharedConsumer

public MessageConsumer createSharedConsumer(Topic topic,
                                            String sharedSubscriptionName,
                                            String messageSelector)
                                     throws JMSException

Specified by:

createSharedConsumer in interface Session

Throws:

JMSException

createDurableConsumer

public MessageConsumer createDurableConsumer(Topic topic,
                                             String name)
                                      throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createDurableConsumer in interface Session

Throws:

JMSException

createDurableConsumer

public MessageConsumer createDurableConsumer(Topic topic,
                                             String name,
                                             String messageSelector,
                                             boolean noLocal)
                                      throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createDurableConsumer in interface Session

Throws:

JMSException

createSharedDurableConsumer

public MessageConsumer createSharedDurableConsumer(Topic topic,
                                                   String name)
                                            throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createSharedDurableConsumer in interface Session

Throws:

JMSException

createSharedDurableConsumer

public MessageConsumer createSharedDurableConsumer(Topic topic,
                                                   String name,
                                                   String messageSelector)
                                            throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createSharedDurableConsumer in interface Session

Throws:

JMSException