public class ActiveMQXASession extends ActiveMQSession implements javax.jms.QueueSession, javax.jms.TopicSession, javax.jms.XAQueueSession, javax.jms.XATopicSession
Session
,
QueueSession
,
TopicSession
,
XASession
ActiveMQSession.DeliveryListener
acknowledgementMode, asyncDispatch, closed, connection, consumerIdGenerator, consumers, debug, deliveryIdGenerator, executor, INDIVIDUAL_ACKNOWLEDGE, info, MAX_ACK_CONSTANT, producerIdGenerator, producers, redeliveryGuard, sendMutex, sessionAsyncDispatch, started
Constructor and Description |
---|
ActiveMQXASession(ActiveMQXAConnection connection,
SessionId sessionId,
int theAcknowlegeMode,
boolean dispatchAsync) |
Modifier and Type | Method and Description |
---|---|
void |
commit()
Commits all messages done in this transaction and releases any locks
currently held.
|
protected void |
doStartTransaction()
Send TransactionInfo to indicate transaction has started
|
javax.jms.QueueSession |
getQueueSession() |
javax.jms.Session |
getSession() |
javax.jms.TopicSession |
getTopicSession() |
boolean |
getTransacted()
Indicates whether the session is in transacted mode.
|
XAResource |
getXAResource() |
boolean |
isAutoAcknowledge()
Checks whether the session used auto acknowledgment.
|
void |
rollback()
Rolls back any messages done in this transaction and releases any locks
currently held.
|
acknowledge, addConsumer, addProducer, asyncSendPacket, checkClosed, checkMessageListener, close, close, configureMessage, createBlobMessage, createBlobMessage, createBlobMessage, createBlobMessage, createBrowser, createBrowser, createBytesMessage, createConsumer, createConsumer, createConsumer, createConsumer, createConsumer, createConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createPublisher, createQueue, createReceiver, createReceiver, createSender, createStreamMessage, createSubscriber, createSubscriber, createTemporaryQueue, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, dispatch, dispose, getAcknowledgeMode, getBlobTransferPolicy, getConnection, getConnectionExecutor, getDeliveryListener, getLastDeliveredSequenceId, getMessageListener, getNextConsumerId, getNextDeliveryId, getNextProducerId, getScheduler, getSessionId, getSessionInfo, getSessionStats, getStats, getTransactionContext, getTransformer, getUnconsumedMessages, hasUncomsumedMessages, isAsyncDispatch, isClientAcknowledge, isClosed, isDupsOkAcknowledge, isIndividualAcknowledge, isInUse, isRunning, isSessionAsyncDispatch, isTransacted, recover, redispatch, removeConsumer, removeProducer, run, send, sendAck, sendAck, setAsyncDispatch, setBlobTransferPolicy, setDeliveryListener, setMessageListener, setOptimizeAcknowledge, setPrefetchSize, setSessionAsyncDispatch, setTransactionContext, setTransformer, start, stop, syncSendPacket, toString, unsubscribe
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
createBrowser, createBrowser, createQueue, createReceiver, createReceiver, createSender, createTemporaryQueue
createDurableSubscriber, createDurableSubscriber, createPublisher, createSubscriber, createSubscriber, createTemporaryTopic, createTopic, unsubscribe
close, createBytesMessage, createConsumer, createConsumer, createConsumer, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createStreamMessage, createTextMessage, createTextMessage, getAcknowledgeMode, getMessageListener, recover, run, setMessageListener
public ActiveMQXASession(ActiveMQXAConnection connection, SessionId sessionId, int theAcknowlegeMode, boolean dispatchAsync) throws javax.jms.JMSException
javax.jms.JMSException
public boolean getTransacted() throws javax.jms.JMSException
ActiveMQSession
getTransacted
in interface javax.jms.Session
getTransacted
in interface javax.jms.XASession
getTransacted
in class ActiveMQSession
javax.jms.JMSException
- if there is some internal error.public void rollback() throws javax.jms.JMSException
ActiveMQSession
rollback
in interface javax.jms.Session
rollback
in interface javax.jms.XASession
rollback
in class ActiveMQSession
javax.jms.JMSException
- if the JMS provider fails to roll back the
transaction due to some internal error.javax.jms.IllegalStateException
- if the method is not called by a
transacted session.public void commit() throws javax.jms.JMSException
ActiveMQSession
commit
in interface javax.jms.Session
commit
in interface javax.jms.XASession
commit
in class ActiveMQSession
javax.jms.JMSException
- if the JMS provider fails to commit the transaction
due to some internal error.javax.jms.TransactionRolledBackException
- if the transaction is rolled back
due to some internal error during commit.javax.jms.IllegalStateException
- if the method is not called by a
transacted session.public javax.jms.Session getSession() throws javax.jms.JMSException
getSession
in interface javax.jms.XASession
javax.jms.JMSException
public XAResource getXAResource()
getXAResource
in interface javax.jms.XASession
public javax.jms.QueueSession getQueueSession() throws javax.jms.JMSException
getQueueSession
in interface javax.jms.XAQueueSession
javax.jms.JMSException
public javax.jms.TopicSession getTopicSession() throws javax.jms.JMSException
getTopicSession
in interface javax.jms.XATopicSession
javax.jms.JMSException
public boolean isAutoAcknowledge()
ActiveMQSession
isAutoAcknowledge
in class ActiveMQSession
protected void doStartTransaction() throws javax.jms.JMSException
ActiveMQSession
doStartTransaction
in class ActiveMQSession
javax.jms.JMSException
- if some internal error occursCopyright © 2005–2019 The Apache Software Foundation. All rights reserved.