public class XAResourceImpl extends Object implements XAResource, ActionListener
Modifier and Type | Field and Description |
---|---|
protected Hashtable<Xid,Xid> |
_activeEmptyTransactions |
protected ISpaceProxy |
_proxy |
protected ExtendedTransactionManager |
m_txnManger |
TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY
Constructor and Description |
---|
XAResourceImpl(TransactionManager txnManger,
IJSpace proxy) |
XAResourceImpl(TransactionManager txnManger,
IJSpace proxy,
boolean delegatedXa,
boolean resourcePerSingleTxn)
Ctor
|
Modifier and Type | Method and Description |
---|---|
void |
action(Transaction txn)
Called by ActionMaker on event
|
void |
commit(Xid xid,
boolean onePhase) |
protected Xid |
createGSXid(Xid xid) |
void |
end(Xid xid,
int flag) |
void |
forget(Xid xid) |
UUID |
getRmid() |
int |
getTransactionTimeout() |
boolean |
isSameRM(XAResource xares) |
int |
prepare(Xid xid) |
Xid[] |
recover(int flag) |
void |
rollback(Xid xid) |
boolean |
setTransactionTimeout(int timeout) |
void |
start(Xid xid,
int flag) |
protected Transaction.Created |
startIn(Xid xid,
int flag,
boolean setAsDefault) |
protected final ExtendedTransactionManager m_txnManger
protected ISpaceProxy _proxy
public XAResourceImpl(TransactionManager txnManger, IJSpace proxy, boolean delegatedXa, boolean resourcePerSingleTxn)
txnManger
- transaction manger, for used inside GS.public XAResourceImpl(TransactionManager txnManger, IJSpace proxy)
public int getTransactionTimeout() throws XAException
getTransactionTimeout
in interface XAResource
XAException
public boolean setTransactionTimeout(int timeout) throws XAException
setTransactionTimeout
in interface XAResource
XAException
public boolean isSameRM(XAResource xares) throws XAException
isSameRM
in interface XAResource
XAException
public UUID getRmid()
public Xid[] recover(int flag) throws XAException
recover
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 void rollback(Xid xid) throws XAException
rollback
in interface XAResource
XAException
public void end(Xid xid, int flag) throws XAException
end
in interface XAResource
XAException
public void start(Xid xid, int flag) throws XAException
start
in interface XAResource
XAException
protected Transaction.Created startIn(Xid xid, int flag, boolean setAsDefault) throws XAException
XAException
public void commit(Xid xid, boolean onePhase) throws XAException
commit
in interface XAResource
XAException
public void action(Transaction txn)
ActionListener
action
in interface ActionListener
Copyright © GigaSpaces.