public class OutboundTopicSession extends OutboundSession implements javax.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 org.objectweb.util.monolog.api.Logger |
logger |
cnx, sess, started, transacted, valid
Constructor and Description |
---|
OutboundTopicSession(javax.jms.Session sess,
OutboundConnection cnx)
Constructs an
OutboundTopicSession instance. |
OutboundTopicSession(javax.jms.Session sess,
OutboundConnection cnx,
boolean transacted)
Constructs an
OutboundTopicSession instance. |
Modifier and Type | Method and Description |
---|---|
javax.jms.QueueBrowser |
createBrowser(javax.jms.Queue queue)
API method.
|
javax.jms.QueueBrowser |
createBrowser(javax.jms.Queue queue,
String selector)
API method.
|
javax.jms.TopicPublisher |
createPublisher(javax.jms.Topic topic)
Delegates the call to the wrapped JMS session.
|
javax.jms.Queue |
createQueue(String queueName)
API method.
|
javax.jms.TopicSubscriber |
createSubscriber(javax.jms.Topic topic)
Delegates the call to the wrapped JMS session.
|
javax.jms.TopicSubscriber |
createSubscriber(javax.jms.Topic topic,
String selector)
Delegates the call to the wrapped JMS session.
|
javax.jms.TopicSubscriber |
createSubscriber(javax.jms.Topic topic,
String selector,
boolean noLocal)
Delegates the call to the wrapped JMS session.
|
javax.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, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createStreamMessage, createTextMessage, createTextMessage, getAcknowledgeMode, getMessageListener, getTransacted, recover, rollback, run, setMessageListener
OutboundTopicSession(javax.jms.Session sess, OutboundConnection cnx)
OutboundTopicSession
instance.OutboundTopicSession(javax.jms.Session sess, OutboundConnection cnx, boolean transacted)
OutboundTopicSession
instance.public javax.jms.TopicPublisher createPublisher(javax.jms.Topic topic) throws javax.jms.JMSException
createPublisher
in interface javax.jms.TopicSession
javax.jms.JMSException
public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic, String selector, boolean noLocal) throws javax.jms.JMSException
createSubscriber
in interface javax.jms.TopicSession
javax.jms.JMSException
public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic, String selector) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic) throws javax.jms.JMSException
createSubscriber
in interface javax.jms.TopicSession
javax.jms.JMSException
public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue, String selector) throws javax.jms.JMSException
createBrowser
in interface javax.jms.Session
createBrowser
in class OutboundSession
javax.jms.IllegalStateException
- Systematically.javax.jms.JMSException
public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue) throws javax.jms.JMSException
createBrowser
in interface javax.jms.Session
createBrowser
in class OutboundSession
javax.jms.IllegalStateException
- Systematically.javax.jms.JMSException
public javax.jms.Queue createQueue(String queueName) throws javax.jms.JMSException
createQueue
in interface javax.jms.Session
createQueue
in class OutboundSession
javax.jms.IllegalStateException
- Systematically.javax.jms.JMSException
public javax.jms.TemporaryQueue createTemporaryQueue() throws javax.jms.JMSException
createTemporaryQueue
in interface javax.jms.Session
createTemporaryQueue
in class OutboundSession
javax.jms.IllegalStateException
- Systematically.javax.jms.JMSException
Copyright © 2018 ScalAgent D.T.. All Rights Reserved.