Package org.infinispan.transaction.xa

Class TransactionXaAdapter

java.lang.Object

org.infinispan.transaction.impl.AbstractEnlistmentAdapter

org.infinispan.transaction.xa.TransactionXaAdapter

All Implemented Interfaces:

javax.transaction.xa.XAResource

public class TransactionXaAdapter
extends org.infinispan.transaction.impl.AbstractEnlistmentAdapter
implements javax.transaction.xa.XAResource

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
void	commit(javax.transaction.xa.Xid externalXid, boolean isOnePhase)	Same comment as for prepare(javax.transaction.xa.Xid) applies for commit.
void	end(javax.transaction.xa.Xid externalXid, int i)
boolean	equals(java.lang.Object o)
void	forget(javax.transaction.xa.Xid externalXid)
LocalXaTransaction	getLocalTransaction()
int	getTransactionTimeout()
boolean	isSameRM(javax.transaction.xa.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(javax.transaction.xa.Xid externalXid)	This can be call for any transaction object.
javax.transaction.xa.Xid[]	recover(int flag)
void	rollback(javax.transaction.xa.Xid externalXid)	Same comment as for prepare(javax.transaction.xa.Xid) applies for commit.
boolean	setTransactionTimeout(int i)
void	start(javax.transaction.xa.Xid externalXid, int i)
java.lang.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 Detail

TransactionXaAdapter

public TransactionXaAdapter(LocalXaTransaction localTransaction,
                            XaTransactionTable txTable)

TransactionXaAdapter

public TransactionXaAdapter(XaTransactionTable txTable)

Method Detail

prepare

public int prepare(javax.transaction.xa.Xid externalXid)
            throws javax.transaction.xa.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 javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

commit

public void commit(javax.transaction.xa.Xid externalXid,
                   boolean isOnePhase)
            throws javax.transaction.xa.XAException

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

Specified by:

commit in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

rollback

public void rollback(javax.transaction.xa.Xid externalXid)
              throws javax.transaction.xa.XAException

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

Specified by:

rollback in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

start

public void start(javax.transaction.xa.Xid externalXid,
                  int i)
           throws javax.transaction.xa.XAException

Specified by:

start in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

end

public void end(javax.transaction.xa.Xid externalXid,
                int i)
         throws javax.transaction.xa.XAException

Specified by:

end in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

forget

public void forget(javax.transaction.xa.Xid externalXid)
            throws javax.transaction.xa.XAException

Specified by:

forget in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

getTransactionTimeout

public int getTransactionTimeout()
                          throws javax.transaction.xa.XAException

Specified by:

getTransactionTimeout in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

isSameRM

public boolean isSameRM(javax.transaction.xa.XAResource xaResource)
                 throws javax.transaction.xa.XAException

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 javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

recover

public javax.transaction.xa.Xid[] recover(int flag)
                                   throws javax.transaction.xa.XAException

Specified by:

recover in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

setTransactionTimeout

public boolean setTransactionTimeout(int i)
                              throws javax.transaction.xa.XAException

Specified by:

setTransactionTimeout in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getLocalTransaction

public LocalXaTransaction getLocalTransaction()

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object