public class OutboundQueueSession extends OutboundSession implements jakarta.jms.QueueSession
OutboundQueueSession
instance wraps a JMS QueueSession
(XA or not) for a component involved in PTP outbound messaging.Modifier and Type | Field and Description |
---|---|
static Logger |
logger |
cnx, sess, started, transacted, valid
Constructor and 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. |
Modifier and Type | Method and 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.
|
String |
toString() |
void |
unsubscribe(String name)
API method.
|
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
createBrowser, createBrowser, createQueue, createTemporaryQueue
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
public static Logger logger
OutboundQueueSession(jakarta.jms.Session sess, OutboundConnection cnx)
OutboundQueueSession
instance.OutboundQueueSession(jakarta.jms.Session sess, OutboundConnection cnx, boolean transacted)
OutboundQueueSession
instance.public String toString()
toString
in class OutboundSession
public jakarta.jms.QueueSender createSender(jakarta.jms.Queue queue) throws jakarta.jms.JMSException
createSender
in interface jakarta.jms.QueueSession
jakarta.jms.JMSException
public jakarta.jms.QueueReceiver createReceiver(jakarta.jms.Queue queue, String selector) throws jakarta.jms.JMSException
createReceiver
in interface jakarta.jms.QueueSession
jakarta.jms.JMSException
public jakarta.jms.QueueReceiver createReceiver(jakarta.jms.Queue queue) throws jakarta.jms.JMSException
createReceiver
in interface jakarta.jms.QueueSession
jakarta.jms.JMSException
public jakarta.jms.TopicSubscriber createDurableSubscriber(jakarta.jms.Topic topic, String name, String selector, boolean noLocal) throws jakarta.jms.JMSException
createDurableSubscriber
in interface jakarta.jms.Session
createDurableSubscriber
in class OutboundSession
jakarta.jms.IllegalStateException
- Systematically.jakarta.jms.JMSException
public jakarta.jms.TopicSubscriber createDurableSubscriber(jakarta.jms.Topic topic, String name) throws jakarta.jms.JMSException
createDurableSubscriber
in interface jakarta.jms.Session
createDurableSubscriber
in class OutboundSession
jakarta.jms.IllegalStateException
- Systematically.jakarta.jms.JMSException
public jakarta.jms.Topic createTopic(String topicName) throws jakarta.jms.JMSException
createTopic
in interface jakarta.jms.Session
createTopic
in class OutboundSession
jakarta.jms.IllegalStateException
- Systematically.jakarta.jms.JMSException
public jakarta.jms.TemporaryTopic createTemporaryTopic() throws jakarta.jms.JMSException
createTemporaryTopic
in interface jakarta.jms.Session
createTemporaryTopic
in class OutboundSession
jakarta.jms.IllegalStateException
- Systematically.jakarta.jms.JMSException
public void unsubscribe(String name) throws jakarta.jms.JMSException
unsubscribe
in interface jakarta.jms.Session
unsubscribe
in class OutboundSession
jakarta.jms.IllegalStateException
- Systematically.jakarta.jms.JMSException
Copyright © 2022 ScalAgent D.T.. All rights reserved.