public class OutboundTopicSession extends OutboundSession implements jakarta.jms.TopicSession
OutboundTopicSession
instance wraps a JMS TopicSession
(XA or not) for a component involved in PubSub outbound messaging.Modifier and Type | Field and Description |
---|---|
static Logger |
logger |
cnx, sess, started, transacted, valid
Constructor and 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. |
Modifier and Type | Method and 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.
|
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
createDurableSubscriber, createDurableSubscriber, createTemporaryTopic, createTopic, unsubscribe
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
OutboundTopicSession(jakarta.jms.Session sess, OutboundConnection cnx)
OutboundTopicSession
instance.OutboundTopicSession(jakarta.jms.Session sess, OutboundConnection cnx, boolean transacted)
OutboundTopicSession
instance.public jakarta.jms.TopicPublisher createPublisher(jakarta.jms.Topic topic) throws jakarta.jms.JMSException
createPublisher
in interface jakarta.jms.TopicSession
jakarta.jms.JMSException
public jakarta.jms.TopicSubscriber createSubscriber(jakarta.jms.Topic topic, String selector, boolean noLocal) throws jakarta.jms.JMSException
createSubscriber
in interface jakarta.jms.TopicSession
jakarta.jms.JMSException
public jakarta.jms.TopicSubscriber createSubscriber(jakarta.jms.Topic topic) throws jakarta.jms.JMSException
createSubscriber
in interface jakarta.jms.TopicSession
jakarta.jms.JMSException
public jakarta.jms.QueueBrowser createBrowser(jakarta.jms.Queue queue, String selector) throws jakarta.jms.JMSException
createBrowser
in interface jakarta.jms.Session
createBrowser
in class OutboundSession
jakarta.jms.IllegalStateException
- Systematically.jakarta.jms.JMSException
public jakarta.jms.QueueBrowser createBrowser(jakarta.jms.Queue queue) throws jakarta.jms.JMSException
createBrowser
in interface jakarta.jms.Session
createBrowser
in class OutboundSession
jakarta.jms.IllegalStateException
- Systematically.jakarta.jms.JMSException
public jakarta.jms.Queue createQueue(String queueName) throws jakarta.jms.JMSException
createQueue
in interface jakarta.jms.Session
createQueue
in class OutboundSession
jakarta.jms.IllegalStateException
- Systematically.jakarta.jms.JMSException
public jakarta.jms.TemporaryQueue createTemporaryQueue() throws jakarta.jms.JMSException
createTemporaryQueue
in interface jakarta.jms.Session
createTemporaryQueue
in class OutboundSession
jakarta.jms.IllegalStateException
- Systematically.jakarta.jms.JMSException
Copyright © 2023 ScalAgent D.T.. All rights reserved.