com.gigaspaces.internal.sync.mirror

Class MirrorReplicationInTransactionHandler

java.lang.Object

com.gigaspaces.internal.sync.mirror.MirrorReplicationInHandler

com.gigaspaces.internal.sync.mirror.MirrorReplicationInTransactionHandler

All Implemented Interfaces:

IReplicationInTransactionHandler, ITransactionalBatchExecutionCallback

public class MirrorReplicationInTransactionHandler
extends MirrorReplicationInHandler
implements IReplicationInTransactionHandler

Handles replicated transaction on mirror. Each transaction is executed separately. non transactional operations are aggregated for better performance

Since:

8.0

Field Summary

Fields inherited from class com.gigaspaces.internal.sync.mirror.MirrorReplicationInHandler

_syncEndpoint

Constructor Summary

Constructors

Constructor and Description
MirrorReplicationInTransactionHandler(MirrorBulkExecutor bulkExecutor, MirrorStatisticsImpl operationStatisticsHandler)

Method Summary

Modifier and Type	Method and Description
void	inTransaction(IReplicationInContext context, ITransactionInContext transactionContext) Handles one phase commit transaction (single participant)
void	inTransactionAbort(IReplicationInContext context, ITransactionInContext transactionContext) Handle abort stage of two phase committed transaction
void	inTransactionCommit(IReplicationInContext context, ITransactionInContext transactionContext) Handle commit stage of two phase committed transaction
void	inTransactionPrepare(IReplicationInContext context, ITransactionInContext transactionContext) Handle prepare stage of two phase committed transaction

Methods inherited from class com.gigaspaces.internal.sync.mirror.MirrorReplicationInHandler

addChangeEntry, addRemoveEntry, addTransaction, addUpdateEntry, addWriteEntry, changeEntry, execute, getTypeManager, removeEntry, removeEntryByUID, updateEntry, writeEntry

Methods inherited from class java.lang.Object

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

Constructor Detail

MirrorReplicationInTransactionHandler

public MirrorReplicationInTransactionHandler(MirrorBulkExecutor bulkExecutor,
                                             MirrorStatisticsImpl operationStatisticsHandler)

Method Detail

inTransaction

public void inTransaction(IReplicationInContext context,
                          ITransactionInContext transactionContext)
                   throws Exception

Description copied from interface: IReplicationInTransactionHandler

Handles one phase commit transaction (single participant)

Specified by:

inTransaction in interface IReplicationInTransactionHandler

Throws:

Exception

inTransactionPrepare

public void inTransactionPrepare(IReplicationInContext context,
                                 ITransactionInContext transactionContext)
                          throws Exception

Description copied from interface: IReplicationInTransactionHandler

Handle prepare stage of two phase committed transaction

Specified by:

inTransactionPrepare in interface IReplicationInTransactionHandler

Throws:

Exception

inTransactionCommit

public void inTransactionCommit(IReplicationInContext context,
                                ITransactionInContext transactionContext)
                         throws Exception

Description copied from interface: IReplicationInTransactionHandler

Handle commit stage of two phase committed transaction

Specified by:

inTransactionCommit in interface IReplicationInTransactionHandler

Throws:

Exception

inTransactionAbort

public void inTransactionAbort(IReplicationInContext context,
                               ITransactionInContext transactionContext)
                        throws Exception

Description copied from interface: IReplicationInTransactionHandler

Handle abort stage of two phase committed transaction

Specified by:

inTransactionAbort in interface IReplicationInTransactionHandler

Throws:

Exception