Package org.objectweb.joram.client.connector

Class OutboundTopicSession

java.lang.Object

org.objectweb.joram.client.connector.OutboundSession

org.objectweb.joram.client.connector.OutboundTopicSession

All Implemented Interfaces:

AutoCloseable, Runnable, Session, TopicSession

public class OutboundTopicSession
extends OutboundSession
implements TopicSession

An OutboundTopicSession instance wraps a JMS TopicSession (XA or not) for a component involved in PubSub 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
OutboundTopicSession(Session sess, OutboundConnection cnx)	Constructs an OutboundTopicSession instance.
OutboundTopicSession(Session sess, OutboundConnection cnx, boolean transacted)	Constructs an OutboundTopicSession instance.

Method Summary

Modifier and Type	Method	Description
QueueBrowser	createBrowser(Queue queue)	API method.
QueueBrowser	createBrowser(Queue queue, String selector)	API method.
TopicPublisher	createPublisher(Topic topic)	Delegates the call to the wrapped JMS session.
Queue	createQueue(String queueName)	API method.
TopicSubscriber	createSubscriber(Topic topic)	Delegates the call to the wrapped JMS session.
TopicSubscriber	createSubscriber(Topic topic, String selector, boolean noLocal)	Delegates the call to the wrapped JMS session.
TemporaryQueue	createTemporaryQueue()	API method.

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

checkValidity, close, commit, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableConsumer, createDurableConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createSharedConsumer, createSharedConsumer, createSharedDurableConsumer, createSharedDurableConsumer, createStreamMessage, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, getAcknowledgeMode, getMessageListener, getTransacted, isStarted, recover, rollback, run, setMessageListener, start, toString, unsubscribe

Methods inherited from class java.lang.Object

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

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

Methods inherited from interface javax.jms.TopicSession

createDurableSubscriber, createDurableSubscriber, createTemporaryTopic, createTopic, unsubscribe

Field Detail

logger

private static final Logger logger

DEBUG

private static final boolean DEBUG

Constructor Detail

OutboundTopicSession

OutboundTopicSession(Session sess,
                     OutboundConnection cnx)

Constructs an OutboundTopicSession instance.

OutboundTopicSession

OutboundTopicSession(Session sess,
                     OutboundConnection cnx,
                     boolean transacted)

Constructs an OutboundTopicSession instance.

Method Detail

createPublisher

public TopicPublisher createPublisher(Topic topic)
                               throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createPublisher in interface TopicSession

Throws:

JMSException

createSubscriber

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

Delegates the call to the wrapped JMS session.

Specified by:

createSubscriber in interface TopicSession

Throws:

JMSException

createSubscriber

public TopicSubscriber createSubscriber(Topic topic)
                                 throws JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createSubscriber in interface TopicSession

Throws:

JMSException

createBrowser

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

API method.

Specified by:

createBrowser in interface Session

Overrides:

createBrowser in class OutboundSession

Throws:

IllegalStateException - Systematically.

JMSException

createBrowser

public QueueBrowser createBrowser(Queue queue)
                           throws JMSException

API method.

Specified by:

createBrowser in interface Session

Overrides:

createBrowser in class OutboundSession

Throws:

IllegalStateException - Systematically.

JMSException

createQueue

public Queue createQueue(String queueName)
                  throws JMSException

API method.

Specified by:

createQueue in interface Session

Overrides:

createQueue in class OutboundSession

Throws:

IllegalStateException - Systematically.

JMSException

createTemporaryQueue

public TemporaryQueue createTemporaryQueue()
                                    throws JMSException

API method.

Specified by:

createTemporaryQueue in interface Session

Overrides:

createTemporaryQueue in class OutboundSession

Throws:

jIllegalStateException - Systematically.

JMSException