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, Collection<TransactionLogRecord> logs, UUID txnId, SerializableXID xid, UUID txOwnerUuid, long timeoutMillis, long startTime)
XATransaction(NodeEngine nodeEngine, Xid xid, UUID txOwnerUuid, int timeout, boolean originatedFromClient)

Method Summary

Modifier and Type	Method and Description
void	add(TransactionLogRecord record)
void	begin()
void	commit()
void	commitAsync(BiConsumer callback)
TransactionLogRecord	get(Object key)
UUID	getOwnerUuid()
long	getStartTime()
Transaction.State	getState()
long	getTimeoutMillis()
Collection<TransactionLogRecord>	getTransactionRecords()
TransactionOptions.TransactionType	getTransactionType()
UUID	getTxnId()
SerializableXID	getXid()
boolean	isOriginatedFromClient()
void	prepare()
void	remove(Object key)
void	rollback()
void	rollbackAsync(BiConsumer 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,
                     UUID txOwnerUuid,
                     int timeout,
                     boolean originatedFromClient)

XATransaction

public XATransaction(NodeEngine nodeEngine,
                     Collection<TransactionLogRecord> logs,
                     UUID txnId,
                     SerializableXID xid,
                     UUID 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(BiConsumer callback)

rollback

public void rollback()
              throws IllegalStateException

Specified by:

rollback in interface Transaction

Throws:

IllegalStateException

rollbackAsync

public void rollbackAsync(BiConsumer callback)

getTxnId

public UUID getTxnId()

Specified by:

getTxnId in interface Transaction

getStartTime

public long getStartTime()

getTransactionRecords

public Collection<TransactionLogRecord> getTransactionRecords()

getState

public Transaction.State getState()

Specified by:

getState in interface Transaction

getTransactionType

public TransactionOptions.TransactionType getTransactionType()

Specified by:

getTransactionType 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 UUID getOwnerUuid()

Specified by:

getOwnerUuid in interface Transaction

isOriginatedFromClient

public boolean isOriginatedFromClient()

Specified by:

isOriginatedFromClient in interface Transaction

getXid

public SerializableXID getXid()