public class GlobalOrderReplicationInBatchContext extends AbstractReplicationInBatchContext implements IReplicationInBatchContext
Constructor and Description |
---|
GlobalOrderReplicationInBatchContext(IBatchExecutedCallback batchExecutedCallback,
Logger contextLogger,
int entireBatchSize,
String sourceLookupName,
String groupName) |
Modifier and Type | Method and Description |
---|---|
protected void |
afterBatchConsumed(long lastProcessedKeyInBatch) |
addPendingContext, currentConsumed, getCurrentKey, getEntireBatchSize, getPendingContext, getTagObject, isBatchContext, pendingConsumed, rollback, setCurrentKey, setTagObject, snapshot
getContentContext, getContextLogger, getContextMarker, getGroupName, getLastProcessedKey, getReplicationBlobstoreBulkContext, getSourceLookupName, setContextPacket, setLastProcessedKey, setReplicationBlobstoreBulkContext, supportsDistributedTransactionConsolidation
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addPendingContext, currentConsumed, getEntireBatchSize, getPendingContext, getTagObject, pendingConsumed, setTagObject
getContentContext, getContextLogger, getContextMarker, getGroupName, getLastProcessedKey, getReplicationBlobstoreBulkContext, getSourceLookupName, isBatchContext, setReplicationBlobstoreBulkContext, supportsDistributedTransactionConsolidation
public GlobalOrderReplicationInBatchContext(IBatchExecutedCallback batchExecutedCallback, Logger contextLogger, int entireBatchSize, String sourceLookupName, String groupName)
protected void afterBatchConsumed(long lastProcessedKeyInBatch)
afterBatchConsumed
in class AbstractReplicationInBatchContext
Copyright © GigaSpaces.