Class GlobalOrderReplicationInBatchContext
java.lang.Object
com.gigaspaces.internal.cluster.node.impl.ReplicationInContext
com.gigaspaces.internal.cluster.node.impl.AbstractReplicationInBatchContext
com.gigaspaces.internal.cluster.node.impl.processlog.globalorder.GlobalOrderReplicationInBatchContext
- All Implemented Interfaces:
IReplicationInBatchContext, IReplicationInContext
public class GlobalOrderReplicationInBatchContext
extends AbstractReplicationInBatchContext
implements IReplicationInBatchContext
-
Constructor Summary
ConstructorsConstructorDescriptionGlobalOrderReplicationInBatchContext(IBatchExecutedCallback batchExecutedCallback, org.slf4j.Logger contextLogger, int entireBatchSize, String sourceLookupName, String groupName) -
Method Summary
Modifier and TypeMethodDescriptionprotected voidafterBatchConsumed(long lastProcessedKeyInBatch) Methods inherited from class AbstractReplicationInBatchContext
addPendingContext, currentConsumed, getCurrentKey, getEntireBatchSize, getPendingContext, getTagObject, isBatchContext, pendingConsumed, rollback, setCurrentKey, setTagObject, snapshotMethods inherited from class ReplicationInContext
getContentContext, getContextLogger, getContextMarker, getGroupName, getLastProcessedKey, getReplicationBlobstoreBulkContext, getSourceLookupName, setContextPacket, setLastProcessedKey, setReplicationBlobstoreBulkContext, supportsDistributedTransactionConsolidationMethods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface IReplicationInBatchContext
addPendingContext, currentConsumed, getEntireBatchSize, getPendingContext, getTagObject, pendingConsumed, setTagObject
-
Constructor Details
-
GlobalOrderReplicationInBatchContext
public GlobalOrderReplicationInBatchContext(IBatchExecutedCallback batchExecutedCallback, org.slf4j.Logger contextLogger, int entireBatchSize, String sourceLookupName, String groupName)
-
-
Method Details
-
afterBatchConsumed
protected void afterBatchConsumed(long lastProcessedKeyInBatch) - Specified by:
afterBatchConsumedin classAbstractReplicationInBatchContext
-