public class OutboundTopicSession extends OutboundSession implements 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
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
Constructor and Description |
---|
OutboundTopicSession(Session sess,
OutboundConnection cnx)
Constructs an
OutboundTopicSession instance. |
OutboundTopicSession(Session sess,
OutboundConnection cnx,
boolean transacted)
Constructs an
OutboundTopicSession instance. |
Modifier and Type | Method and 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)
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.
|
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, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createStreamMessage, createTextMessage, createTextMessage, getAcknowledgeMode, getMessageListener, getTransacted, recover, rollback, run, setMessageListener
public static Logger logger
OutboundTopicSession(Session sess, OutboundConnection cnx)
OutboundTopicSession
instance.OutboundTopicSession(Session sess, OutboundConnection cnx, boolean transacted)
OutboundTopicSession
instance.public TopicPublisher createPublisher(Topic topic) throws JMSException
createPublisher
in interface TopicSession
JMSException
public TopicSubscriber createSubscriber(Topic topic, String selector, boolean noLocal) throws JMSException
createSubscriber
in interface TopicSession
JMSException
public TopicSubscriber createSubscriber(Topic topic, String selector) throws JMSException
JMSException
public TopicSubscriber createSubscriber(Topic topic) throws JMSException
createSubscriber
in interface TopicSession
JMSException
public QueueBrowser createBrowser(Queue queue, String selector) throws JMSException
createBrowser
in interface Session
createBrowser
in class OutboundSession
IllegalStateException
- Systematically.JMSException
public QueueBrowser createBrowser(Queue queue) throws JMSException
createBrowser
in interface Session
createBrowser
in class OutboundSession
IllegalStateException
- Systematically.JMSException
public Queue createQueue(String queueName) throws JMSException
createQueue
in interface Session
createQueue
in class OutboundSession
IllegalStateException
- Systematically.JMSException
public TemporaryQueue createTemporaryQueue() throws JMSException
createTemporaryQueue
in interface Session
createTemporaryQueue
in class OutboundSession
IllegalStateException
- Systematically.JMSException
Copyright © 2023 ScalAgent D.T.. All rights reserved.