com.gigaspaces.internal.sync.mirror

Class MirrorReplicationInAggregatedTransactionHandler

java.lang.Object

com.gigaspaces.internal.sync.mirror.MirrorReplicationInHandler

com.gigaspaces.internal.sync.mirror.MirrorReplicationInAggregatedTransactionHandler

All Implemented Interfaces:

IReplicationInTransactionHandler, ITransactionalBatchExecutionCallback

public class MirrorReplicationInAggregatedTransactionHandler
extends MirrorReplicationInHandler
implements IReplicationInTransactionHandler

Handles replicated transaction on mirror in batches. Several transaction are aggregated into a single transaction 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
MirrorReplicationInAggregatedTransactionHandler(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

MirrorReplicationInAggregatedTransactionHandler

public MirrorReplicationInAggregatedTransactionHandler(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