com.hazelcast.transaction.impl.xa

Class XATransaction

java.lang.Object

com.hazelcast.transaction.impl.xa.XATransaction

All Implemented Interfaces:

Transaction

public final class XATransaction
extends Object
implements Transaction

XA Transaction implementation. This class does not need to be thread-safe, it is only used via XAResource All visibility guarantees handled by XAResource

Nested Class Summary

Nested classes/interfaces inherited from interface com.hazelcast.transaction.impl.Transaction

Transaction.State

Constructor Summary

Constructors

Constructor and Description
XATransaction(NodeEngine nodeEngine, List<TransactionLogRecord> logs, String txnId, SerializableXID xid, String txOwnerUuid, long timeoutMillis, long startTime)
XATransaction(NodeEngine nodeEngine, Xid xid, String txOwnerUuid, int timeout)

Method Summary

Methods

Modifier and Type	Method and Description
void	add(TransactionLogRecord record)
void	begin()
void	commit()
void	commitAsync(ExecutionCallback callback)
TransactionLogRecord	get(Object key)
String	getOwnerUuid()
long	getStartTime()
Transaction.State	getState()
long	getTimeoutMillis()
List<TransactionLogRecord>	getTransactionRecords()
String	getTxnId()
SerializableXID	getXid()
void	prepare()
void	remove(Object key)
void	rollback()
void	rollbackAsync(ExecutionCallback callback)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

XATransaction

public XATransaction(NodeEngine nodeEngine,
             Xid xid,
             String txOwnerUuid,
             int timeout)

XATransaction

public XATransaction(NodeEngine nodeEngine,
             List<TransactionLogRecord> logs,
             String txnId,
             SerializableXID xid,
             String txOwnerUuid,
             long timeoutMillis,
             long startTime)

Method Detail

begin

public void begin()
           throws IllegalStateException

Specified by:

begin in interface Transaction

Throws:

IllegalStateException

prepare

public void prepare()
             throws TransactionException

Specified by:

prepare in interface Transaction

Throws:

TransactionException

commit

public void commit()
            throws TransactionException,
                   IllegalStateException

Specified by:

commit in interface Transaction

Throws:

TransactionException

IllegalStateException

commitAsync

public void commitAsync(ExecutionCallback callback)

rollback

public void rollback()
              throws IllegalStateException

Specified by:

rollback in interface Transaction

Throws:

IllegalStateException

rollbackAsync

public void rollbackAsync(ExecutionCallback callback)

getTxnId

public String getTxnId()

Specified by:

getTxnId in interface Transaction

getStartTime

public long getStartTime()

getTransactionRecords

public List<TransactionLogRecord> getTransactionRecords()

getState

public Transaction.State getState()

Specified by:

getState in interface Transaction

getTimeoutMillis

public long getTimeoutMillis()

Specified by:

getTimeoutMillis in interface Transaction

add

public void add(TransactionLogRecord record)

Specified by:

add in interface Transaction

remove

public void remove(Object key)

Specified by:

remove in interface Transaction

get

public TransactionLogRecord get(Object key)

Specified by:

get in interface Transaction

getOwnerUuid

public String getOwnerUuid()

Specified by:

getOwnerUuid in interface Transaction

getXid

public SerializableXID getXid()