Package org.infinispan.transaction.xa

Class TransactionXaAdapter

java.lang.Object

org.infinispan.transaction.impl.AbstractEnlistmentAdapter

org.infinispan.transaction.xa.TransactionXaAdapter

All Implemented Interfaces:

XAResource, AsyncXaResource

public class TransactionXaAdapter
extends AbstractEnlistmentAdapter
implements XAResource, AsyncXaResource

This acts both as an local CacheTransaction and implementor of an XAResource that will be called by tx manager on various tx stages.

Since:

4.0

Author:

Mircea.Markus@jboss.com

Field Summary

Fields inherited from interface javax.transaction.xa.XAResource

TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY

Constructor Summary

Constructors

Constructor	Description
TransactionXaAdapter(LocalXaTransaction localTransaction, XaTransactionTable txTable)
TransactionXaAdapter(XaTransactionTable txTable)

Method Summary

Modifier and Type	Method	Description
CompletionStage<Void>	asyncCommit(XidImpl xid, boolean onePhase)
CompletionStage<Void>	asyncEnd(XidImpl xid, int flags)
CompletionStage<Integer>	asyncPrepare(XidImpl xid)
CompletionStage<Void>	asyncRollback(XidImpl xid)
void	commit(Xid externalXid, boolean isOnePhase)	Same comment as for prepare(javax.transaction.xa.Xid) applies for commit.
void	end(Xid externalXid, int i)
boolean	equals(Object o)
void	forget(Xid externalXid)
LocalXaTransaction	getLocalTransaction()
int	getTransactionTimeout()
boolean	isSameRM(XAResource xaResource)	the only situation in which it returns true is when the other xa resource pertains to the same cache, on the same node.
int	prepare(Xid externalXid)	This can be call for any transaction object.
Xid[]	recover(int flag)
void	rollback(Xid externalXid)	Same comment as for prepare(javax.transaction.xa.Xid) applies for commit.
boolean	setTransactionTimeout(int i)
void	start(Xid externalXid, int i)
String	toString()

Methods inherited from class org.infinispan.transaction.impl.AbstractEnlistmentAdapter

hashCode

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

TransactionXaAdapter

public TransactionXaAdapter(LocalXaTransaction localTransaction,
 XaTransactionTable txTable)

TransactionXaAdapter

public TransactionXaAdapter(XaTransactionTable txTable)

Method Details

prepare

public int prepare(Xid externalXid)
            throws XAException

This can be call for any transaction object. See Section 3.4.6 (Resource Sharing) from JTA spec v1.1.

Specified by:

prepare in interface XAResource

Throws:

XAException

commit

public void commit(Xid externalXid,
 boolean isOnePhase)
            throws XAException

Same comment as for prepare(javax.transaction.xa.Xid) applies for commit.

Specified by:

commit in interface XAResource

Throws:

XAException

rollback

public void rollback(Xid externalXid)
              throws XAException

Same comment as for prepare(javax.transaction.xa.Xid) applies for commit.

Specified by:

rollback in interface XAResource

Throws:

XAException

start

public void start(Xid externalXid,
 int i)
           throws XAException

Specified by:

start in interface XAResource

Throws:

XAException

end

public void end(Xid externalXid,
 int i)

Specified by:

end in interface XAResource

forget

public void forget(Xid externalXid)
            throws XAException

Specified by:

forget in interface XAResource

Throws:

XAException

getTransactionTimeout

public int getTransactionTimeout()

Specified by:

getTransactionTimeout in interface XAResource

isSameRM

public boolean isSameRM(XAResource xaResource)

the only situation in which it returns true is when the other xa resource pertains to the same cache, on the same node.

Specified by:

isSameRM in interface XAResource

recover

public Xid[] recover(int flag)

Specified by:

recover in interface XAResource

setTransactionTimeout

public boolean setTransactionTimeout(int i)

Specified by:

setTransactionTimeout in interface XAResource

toString

public String toString()

Overrides:

toString in class Object

getLocalTransaction

public LocalXaTransaction getLocalTransaction()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

asyncEnd

public CompletionStage<Void> asyncEnd(XidImpl xid,
 int flags)

Specified by:

asyncEnd in interface AsyncXaResource

Returns:

A CompletionStage which is completed with the result of XAResource.end(Xid, int).

See Also:

• XAResource.end(Xid, int)

asyncPrepare

public CompletionStage<Integer> asyncPrepare(XidImpl xid)

Specified by:

asyncPrepare in interface AsyncXaResource

Returns:

A CompletionStage which is completed with the result of XAResource.prepare(Xid).

See Also:

• XAResource.prepare(Xid)

asyncCommit

public CompletionStage<Void> asyncCommit(XidImpl xid,
 boolean onePhase)

Specified by:

asyncCommit in interface AsyncXaResource

Returns:

A CompletionStage which is completed with the result of XAResource.commit(Xid, boolean)

See Also:

• XAResource.commit(Xid, boolean)

asyncRollback

public CompletionStage<Void> asyncRollback(XidImpl xid)

Specified by:

asyncRollback in interface AsyncXaResource

Returns:

A CompletionStage which is completed with the result of XAResource.rollback(Xid)

See Also:

• XAResource.rollback(Xid)