Package org.ow2.joram.jakarta.connector

Class OutboundQueueSession

java.lang.Object

org.ow2.joram.jakarta.connector.OutboundSession

org.ow2.joram.jakarta.connector.OutboundQueueSession

All Implemented Interfaces:

jakarta.jms.QueueSession, jakarta.jms.Session, AutoCloseable, Runnable

public class OutboundQueueSession
extends OutboundSession
implements jakarta.jms.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.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
OutboundQueueSession(jakarta.jms.Session sess, OutboundConnection cnx)	Constructs an OutboundQueueSession instance.
OutboundQueueSession(jakarta.jms.Session sess, OutboundConnection cnx, boolean transacted)	Constructs an OutboundQueueSession instance.

Method Summary

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

Methods inherited from class org.ow2.joram.jakarta.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 jakarta.jms.QueueSession

createBrowser, createBrowser, createQueue, createTemporaryQueue

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

Field Detail

logger

private static final Logger logger

DEBUG

private static final boolean DEBUG

Constructor Detail

OutboundQueueSession

OutboundQueueSession(jakarta.jms.Session sess,
                     OutboundConnection cnx)

Constructs an OutboundQueueSession instance.

OutboundQueueSession

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

Constructs an OutboundQueueSession instance.

Method Detail

createSender

public jakarta.jms.QueueSender createSender(jakarta.jms.Queue queue)
                                     throws jakarta.jms.JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createSender in interface jakarta.jms.QueueSession

Throws:

jakarta.jms.JMSException

createReceiver

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

Delegates the call to the wrapped JMS session.

Specified by:

createReceiver in interface jakarta.jms.QueueSession

Throws:

jakarta.jms.JMSException

createReceiver

public jakarta.jms.QueueReceiver createReceiver(jakarta.jms.Queue queue)
                                         throws jakarta.jms.JMSException

Delegates the call to the wrapped JMS session.

Specified by:

createReceiver in interface jakarta.jms.QueueSession

Throws:

jakarta.jms.JMSException

createDurableSubscriber

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

API method.

Specified by:

createDurableSubscriber in interface jakarta.jms.Session

Overrides:

createDurableSubscriber in class OutboundSession

Throws:

jakarta.jms.IllegalStateException - Systematically.

jakarta.jms.JMSException

createDurableSubscriber

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

API method.

Specified by:

createDurableSubscriber in interface jakarta.jms.Session

Overrides:

createDurableSubscriber in class OutboundSession

Throws:

jakarta.jms.IllegalStateException - Systematically.

jakarta.jms.JMSException

createTopic

public jakarta.jms.Topic createTopic(String topicName)
                              throws jakarta.jms.JMSException

API method.

Specified by:

createTopic in interface jakarta.jms.Session

Overrides:

createTopic in class OutboundSession

Throws:

jakarta.jms.IllegalStateException - Systematically.

jakarta.jms.JMSException

createTemporaryTopic

public jakarta.jms.TemporaryTopic createTemporaryTopic()
                                                throws jakarta.jms.JMSException

API method.

Specified by:

createTemporaryTopic in interface jakarta.jms.Session

Overrides:

createTemporaryTopic in class OutboundSession

Throws:

jakarta.jms.IllegalStateException - Systematically.

jakarta.jms.JMSException

unsubscribe

public void unsubscribe(String name)
                 throws jakarta.jms.JMSException

API method.

Specified by:

unsubscribe in interface jakarta.jms.Session

Overrides:

unsubscribe in class OutboundSession

Throws:

jakarta.jms.IllegalStateException - Systematically.

jakarta.jms.JMSException