public class OutboundQueueSession extends OutboundSession implements javax.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 org.objectweb.util.monolog.api.Logger |
logger |
cnx, sess, started, transacted, valid
Constructor and Description |
---|
OutboundQueueSession(javax.jms.Session sess,
OutboundConnection cnx)
Constructs an
OutboundQueueSession instance. |
OutboundQueueSession(javax.jms.Session sess,
OutboundConnection cnx,
boolean transacted)
Constructs an
OutboundQueueSession instance. |
Modifier and Type | Method and Description |
---|---|
javax.jms.TopicSubscriber |
createDurableSubscriber(javax.jms.Topic topic,
String name)
API method.
|
javax.jms.TopicSubscriber |
createDurableSubscriber(javax.jms.Topic topic,
String name,
String selector,
boolean noLocal)
API method.
|
javax.jms.QueueReceiver |
createReceiver(javax.jms.Queue queue)
Delegates the call to the wrapped JMS session.
|
javax.jms.QueueReceiver |
createReceiver(javax.jms.Queue queue,
String selector)
Delegates the call to the wrapped JMS session.
|
javax.jms.QueueSender |
createSender(javax.jms.Queue queue)
Delegates the call to the wrapped JMS session.
|
javax.jms.TemporaryTopic |
createTemporaryTopic()
API method.
|
javax.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, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createStreamMessage, createTextMessage, createTextMessage, getAcknowledgeMode, getMessageListener, getTransacted, recover, rollback, run, setMessageListener
OutboundQueueSession(javax.jms.Session sess, OutboundConnection cnx)
OutboundQueueSession
instance.OutboundQueueSession(javax.jms.Session sess, OutboundConnection cnx, boolean transacted)
OutboundQueueSession
instance.public javax.jms.QueueSender createSender(javax.jms.Queue queue) throws javax.jms.JMSException
createSender
in interface javax.jms.QueueSession
javax.jms.JMSException
public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue, String selector) throws javax.jms.JMSException
createReceiver
in interface javax.jms.QueueSession
javax.jms.JMSException
public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue) throws javax.jms.JMSException
createReceiver
in interface javax.jms.QueueSession
javax.jms.JMSException
public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic, String name, String selector, boolean noLocal) throws javax.jms.JMSException
createDurableSubscriber
in interface javax.jms.Session
createDurableSubscriber
in class OutboundSession
javax.jms.IllegalStateException
- Systematically.javax.jms.JMSException
public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic, String name) throws javax.jms.JMSException
createDurableSubscriber
in interface javax.jms.Session
createDurableSubscriber
in class OutboundSession
javax.jms.IllegalStateException
- Systematically.javax.jms.JMSException
public javax.jms.Topic createTopic(String topicName) throws javax.jms.JMSException
createTopic
in interface javax.jms.Session
createTopic
in class OutboundSession
javax.jms.IllegalStateException
- Systematically.javax.jms.JMSException
public javax.jms.TemporaryTopic createTemporaryTopic() throws javax.jms.JMSException
createTemporaryTopic
in interface javax.jms.Session
createTemporaryTopic
in class OutboundSession
javax.jms.IllegalStateException
- Systematically.javax.jms.JMSException
public void unsubscribe(String name) throws javax.jms.JMSException
unsubscribe
in interface javax.jms.Session
unsubscribe
in class OutboundSession
javax.jms.IllegalStateException
- Systematically.javax.jms.JMSException
public String toString()
toString
in class OutboundSession
Copyright © 2018 ScalAgent D.T.. All Rights Reserved.