public class XAQueueSession extends XASession implements XAQueueSession
javax.jms.XAQueueSession
interface.AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
Constructor and Description |
---|
XAQueueSession(XAQueueConnection cnx,
QueueSession qs,
XAResourceMngr rm)
Constructs an
XAQueueSession instance. |
Modifier and Type | Method and Description |
---|---|
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.
|
QueueSession |
getQueueSession()
API method.
|
String |
toString()
Returns a String image of this session.
|
close, commit, createBrowser, createBrowser, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableConsumer, createDurableConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createQueue, createSharedConsumer, createSharedConsumer, createSharedDurableConsumer, createSharedDurableConsumer, createStreamMessage, createTemporaryQueue, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, getAcknowledgeMode, getDelegateSession, getMessageListener, getSession, getTransacted, getXAResource, recover, rollback, run, setMessageListener, unsubscribe
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
commit, getSession, getTransacted, getXAResource, rollback
close, createBrowser, createBrowser, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createQueue, createStreamMessage, createTemporaryQueue, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, getAcknowledgeMode, getMessageListener, recover, run, setMessageListener, unsubscribe
XAQueueSession(XAQueueConnection cnx, QueueSession qs, XAResourceMngr rm) throws JMSException
XAQueueSession
instance.cnx
- The connection the session belongs to.rm
- The resource manager.JMSException
- Actually never thrown.public String toString()
public QueueSession getQueueSession() throws JMSException
getQueueSession
in interface XAQueueSession
JMSException
- if an internal error occurs.public QueueSender createSender(Queue queue) throws JMSException
JMSException
public QueueReceiver createReceiver(Queue queue, String selector) throws JMSException
JMSException
public QueueReceiver createReceiver(Queue queue) throws JMSException
JMSException
Copyright © 2020 ScalAgent D.T.. All rights reserved.