Package org.ow2.joram.jakarta.connector

Class OutboundTopicSession

java.lang.Object

org.ow2.joram.jakarta.connector.OutboundSession

org.ow2.joram.jakarta.connector.OutboundTopicSession

All Implemented Interfaces:

jakarta.jms.Session, jakarta.jms.TopicSession, AutoCloseable, Runnable

public class OutboundTopicSession
extends OutboundSession
implements jakarta.jms.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.ow2.joram.jakarta.connector.OutboundSession

cnx, sess, started, transacted, valid

Fields inherited from interface jakarta.jms.Session

AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED

Constructor Summary

Constructors

Constructor	Description
OutboundTopicSession(jakarta.jms.Session sess, OutboundConnection cnx)	Constructs an OutboundTopicSession instance.
OutboundTopicSession(jakarta.jms.Session sess, OutboundConnection cnx, boolean transacted)	Constructs an OutboundTopicSession instance.

Method Summary

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

Methods inherited from class org.ow2.joram.jakarta.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 jakarta.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 jakarta.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(jakarta.jms.Session sess,
                     OutboundConnection cnx)

Constructs an OutboundTopicSession instance.

OutboundTopicSession

OutboundTopicSession(jakarta.jms.Session sess,
                     OutboundConnection cnx,
                     boolean transacted)

Constructs an OutboundTopicSession instance.

Method Detail

createPublisher

public jakarta.jms.TopicPublisher createPublisher(jakarta.jms.Topic topic)
                                           throws jakarta.jms.JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createPublisher in interface jakarta.jms.TopicSession

Throws:

jakarta.jms.JMSException

createSubscriber

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

Delegates the call to the wrapped JMS session.

Specified by:

createSubscriber in interface jakarta.jms.TopicSession

Throws:

jakarta.jms.JMSException

createSubscriber

public jakarta.jms.TopicSubscriber createSubscriber(jakarta.jms.Topic topic)
                                             throws jakarta.jms.JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createSubscriber in interface jakarta.jms.TopicSession

Throws:

jakarta.jms.JMSException

createBrowser

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

API method.

Specified by:

createBrowser in interface jakarta.jms.Session

Overrides:

createBrowser in class OutboundSession

Throws:

IllegalStateException - Systematically.

jakarta.jms.JMSException

createBrowser

public jakarta.jms.QueueBrowser createBrowser(jakarta.jms.Queue queue)
                                       throws jakarta.jms.JMSException

API method.

Specified by:

createBrowser in interface jakarta.jms.Session

Overrides:

createBrowser in class OutboundSession

Throws:

IllegalStateException - Systematically.

jakarta.jms.JMSException

createQueue

public jakarta.jms.Queue createQueue(String queueName)
                              throws jakarta.jms.JMSException

API method.

Specified by:

createQueue in interface jakarta.jms.Session

Overrides:

createQueue in class OutboundSession

Throws:

IllegalStateException - Systematically.

jakarta.jms.JMSException

createTemporaryQueue

public jakarta.jms.TemporaryQueue createTemporaryQueue()
                                                throws jakarta.jms.JMSException

API method.

Specified by:

createTemporaryQueue in interface jakarta.jms.Session

Overrides:

createTemporaryQueue in class OutboundSession

Throws:

jIllegalStateException - Systematically.

jakarta.jms.JMSException