Class MirrorReplicationInBatchConsumptionHandler

java.lang.Object

com.gigaspaces.internal.sync.mirror.MirrorReplicationInHandler

com.gigaspaces.internal.sync.mirror.MirrorReplicationInBatchConsumptionHandler

All Implemented Interfaces:

IReplicationInBatchConsumptionHandler, ITransactionalBatchExecutionCallback

public class MirrorReplicationInBatchConsumptionHandler
extends MirrorReplicationInHandler
implements IReplicationInBatchConsumptionHandler

Handles batch consumption event sent to the mirror.

Since:

9.0

Author:

idan, eitany

Field Summary

Fields inherited from class MirrorReplicationInHandler

_syncEndpoint

Constructor Summary

Constructors

Constructor	Description
MirrorReplicationInBatchConsumptionHandler(MirrorBulkExecutor bulkExecutor, MirrorStatisticsImpl operationStatisticsHandler)

Method Summary

Modifier and Type	Method	Description
void	consumePendingOperationsInBatch(IReplicationInBatchContext context)	Called after all the incoming replication events for the current batch passed through the corresponding event handlers.

Methods inherited from class MirrorReplicationInHandler

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

Methods inherited from class Object

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

Constructor Details

MirrorReplicationInBatchConsumptionHandler

public MirrorReplicationInBatchConsumptionHandler(MirrorBulkExecutor bulkExecutor,
 MirrorStatisticsImpl operationStatisticsHandler)

Method Details

consumePendingOperationsInBatch

public void consumePendingOperationsInBatch(IReplicationInBatchContext context)
                                     throws Exception

Description copied from interface: IReplicationInBatchConsumptionHandler

Called after all the incoming replication events for the current batch passed through the corresponding event handlers. Any pending unconsumed events should be consumed here.

Specified by:

consumePendingOperationsInBatch in interface IReplicationInBatchConsumptionHandler

Throws:

Exception