public class TransactionalQueueSession extends AbstractQueueSession implements QueueSession
TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY
Constructor and Description |
---|
TransactionalQueueSession(QueueProvider queueProvider,
QueueXaResourceManager xaResourceManager,
AbstractResourceManager resourceManager,
XaTransactionRecoverer xaTransactionRecoverer,
LocalTxQueueTransactionJournal localTxTransactionJournal,
MuleContext muleContext) |
Modifier and Type | Method and Description |
---|---|
void |
begin()
Starts a transaction to execute operations over a set of queue with atomicity.
|
void |
commit()
Commits a transaction started with
QueueSession.begin() |
void |
commit(Xid xid,
boolean onePhase) |
void |
end(Xid xid,
int flags) |
void |
forget(Xid xid) |
protected QueueTransactionContext |
getTransactionalContext() |
int |
getTransactionTimeout() |
boolean |
isSameRM(XAResource xares) |
int |
prepare(Xid xid) |
Xid[] |
recover(int i) |
void |
rollback()
Rollbacks a transaction started with
QueueSession.begin() |
void |
rollback(Xid xid) |
boolean |
setTransactionTimeout(int timeout) |
void |
start(Xid xid,
int flags) |
getMuleContext, getQueue, getQueueProvider
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getQueue
public TransactionalQueueSession(QueueProvider queueProvider, QueueXaResourceManager xaResourceManager, AbstractResourceManager resourceManager, XaTransactionRecoverer xaTransactionRecoverer, LocalTxQueueTransactionJournal localTxTransactionJournal, MuleContext muleContext)
protected QueueTransactionContext getTransactionalContext()
getTransactionalContext
in class AbstractQueueSession
public void begin() throws ResourceManagerException
QueueSession
begin
in interface QueueSession
ResourceManagerException
public void commit() throws ResourceManagerException
QueueSession
QueueSession.begin()
commit
in interface QueueSession
ResourceManagerException
public void rollback() throws ResourceManagerException
QueueSession
QueueSession.begin()
rollback
in interface QueueSession
ResourceManagerException
public boolean isSameRM(XAResource xares) throws XAException
isSameRM
in interface XAResource
XAException
public void start(Xid xid, int flags) throws XAException
start
in interface XAResource
XAException
public void end(Xid xid, int flags) throws XAException
end
in interface XAResource
XAException
public void commit(Xid xid, boolean onePhase) throws XAException
commit
in interface XAResource
XAException
public void rollback(Xid xid) throws XAException
rollback
in interface XAResource
XAException
public int prepare(Xid xid) throws XAException
prepare
in interface XAResource
XAException
public void forget(Xid xid) throws XAException
forget
in interface XAResource
XAException
public int getTransactionTimeout() throws XAException
getTransactionTimeout
in interface XAResource
XAException
public boolean setTransactionTimeout(int timeout) throws XAException
setTransactionTimeout
in interface XAResource
XAException
public Xid[] recover(int i) throws XAException
recover
in interface XAResource
XAException
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.