Package 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:

AutoCloseable, Runnable, QueueSession, Session

public class OutboundQueueSession
extends OutboundSession
implements QueueSession

An OutboundQueueSession instance wraps a JMS QueueSession (XA or not) for a component involved in PTP outbound messaging.

Field Summary

Fields

Modifier and Type	Field	Description
private static boolean	DEBUG
private static Logger	logger

Fields inherited from class org.objectweb.joram.client.connector.OutboundSession

cnx, sess, started, transacted, valid

Fields inherited from interface javax.jms.Session

AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
TopicSubscriber	createDurableSubscriber(Topic topic, String name)	API method.
TopicSubscriber	createDurableSubscriber(Topic topic, String name, String selector, boolean noLocal)	API method.
QueueReceiver	createReceiver(Queue queue)	Delegates the call to the wrapped JMS session.
QueueReceiver	createReceiver(Queue queue, String selector)	Delegates the call to the wrapped JMS session.
QueueSender	createSender(Queue queue)	Delegates the call to the wrapped JMS session.
TemporaryTopic	createTemporaryTopic()	API method.
Topic	createTopic(String topicName)	API method.
void	unsubscribe(String name)	API method.

Methods inherited from class org.objectweb.joram.client.connector.OutboundSession

checkValidity, close, commit, createBrowser, createBrowser, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableConsumer, createDurableConsumer, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createQueue, createSharedConsumer, createSharedConsumer, createSharedDurableConsumer, createSharedDurableConsumer, createStreamMessage, createTemporaryQueue, createTextMessage, createTextMessage, getAcknowledgeMode, getMessageListener, getTransacted, isStarted, recover, rollback, run, setMessageListener, start, toString

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, createDurableConsumer, createDurableConsumer, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createSharedConsumer, createSharedConsumer, createSharedDurableConsumer, createSharedDurableConsumer, createStreamMessage, createTextMessage, createTextMessage, getAcknowledgeMode, getMessageListener, getTransacted, recover, rollback, run, setMessageListener

Field Detail

logger

private static final Logger logger

DEBUG

private static final boolean DEBUG

Constructor Detail

OutboundQueueSession

OutboundQueueSession(Session sess,
                     OutboundConnection cnx)

Constructs an OutboundQueueSession instance.

OutboundQueueSession

OutboundQueueSession(Session sess,
                     OutboundConnection cnx,
                     boolean transacted)

Constructs an OutboundQueueSession instance.

Method Detail

createSender

public QueueSender createSender(Queue queue)
                         throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createSender in interface QueueSession

Throws:

JMSException

createReceiver

public QueueReceiver createReceiver(Queue queue,
                                    String selector)
                             throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createReceiver in interface QueueSession

Throws:

JMSException

createReceiver

public QueueReceiver createReceiver(Queue queue)
                             throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createReceiver in interface QueueSession

Throws:

JMSException

createDurableSubscriber

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

API method.

Specified by:

createDurableSubscriber in interface Session

Overrides:

createDurableSubscriber in class OutboundSession

Throws:

IllegalStateException - Systematically.

JMSException

createDurableSubscriber

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

API method.

Specified by:

createDurableSubscriber in interface Session

Overrides:

createDurableSubscriber in class OutboundSession

Throws:

IllegalStateException - Systematically.

JMSException

createTopic

public Topic createTopic(String topicName)
                  throws JMSException

API method.

Specified by:

createTopic in interface Session

Overrides:

createTopic in class OutboundSession

Throws:

IllegalStateException - Systematically.

JMSException

createTemporaryTopic

public TemporaryTopic createTemporaryTopic()
                                    throws JMSException

API method.

Specified by:

createTemporaryTopic in interface Session

Overrides:

createTemporaryTopic in class OutboundSession

Throws:

IllegalStateException - Systematically.

JMSException

unsubscribe

public void unsubscribe(String name)
                 throws JMSException

API method.

Specified by:

unsubscribe in interface Session

Overrides:

unsubscribe in class OutboundSession

Throws:

IllegalStateException - Systematically.

JMSException