public class OutboundQueueSession extends OutboundSession implements 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
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
Constructor and Description |
---|
OutboundQueueSession(Session sess,
OutboundConnection cnx)
Constructs an
OutboundQueueSession instance. |
OutboundQueueSession(Session sess,
OutboundConnection cnx,
boolean transacted)
Constructs an
OutboundQueueSession instance. |
Modifier and Type | Method and Description |
---|---|
TopicSubscriber |
createDurableSubscriber(Topic topic,
String name)
API method.
|
TopicSubscriber |
createDurableSubscriber(Topic topic,
String name,
String selector,
boolean noLocal)
API method.
|
QueueReceiver |
createReceiver(Queue queue)
Delegates the call to the wrapped JMS session.
|
QueueReceiver |
createReceiver(Queue queue,
String selector)
Delegates the call to the wrapped JMS session.
|
QueueSender |
createSender(Queue queue)
Delegates the call to the wrapped JMS session.
|
TemporaryTopic |
createTemporaryTopic()
API method.
|
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(Session sess, OutboundConnection cnx)
OutboundQueueSession
instance.OutboundQueueSession(Session sess, OutboundConnection cnx, boolean transacted)
OutboundQueueSession
instance.public QueueSender createSender(Queue queue) throws JMSException
createSender
in interface QueueSession
JMSException
public QueueReceiver createReceiver(Queue queue, String selector) throws JMSException
createReceiver
in interface QueueSession
JMSException
public QueueReceiver createReceiver(Queue queue) throws JMSException
createReceiver
in interface QueueSession
JMSException
public TopicSubscriber createDurableSubscriber(Topic topic, String name, String selector, boolean noLocal) throws JMSException
createDurableSubscriber
in interface Session
createDurableSubscriber
in class OutboundSession
IllegalStateException
- Systematically.JMSException
public TopicSubscriber createDurableSubscriber(Topic topic, String name) throws JMSException
createDurableSubscriber
in interface Session
createDurableSubscriber
in class OutboundSession
IllegalStateException
- Systematically.JMSException
public Topic createTopic(String topicName) throws JMSException
createTopic
in interface Session
createTopic
in class OutboundSession
IllegalStateException
- Systematically.JMSException
public TemporaryTopic createTemporaryTopic() throws JMSException
createTemporaryTopic
in interface Session
createTemporaryTopic
in class OutboundSession
IllegalStateException
- Systematically.JMSException
public void unsubscribe(String name) throws JMSException
unsubscribe
in interface Session
unsubscribe
in class OutboundSession
IllegalStateException
- Systematically.JMSException
public String toString()
toString
in class OutboundSession
Copyright © 2020 ScalAgent D.T.. All rights reserved.