public class MultiBucketSingleFileSyncTargetProcessLog extends AbstractMultiBucketSingleFileTargetProcessLog implements IReplicationSyncTargetProcessLog
_dataConsumer, _specificLogger| Constructor and Description |
|---|
MultiBucketSingleFileSyncTargetProcessLog(ProcessLogConfig config,
IReplicationPacketDataConsumer<?> dataConsumer,
IReplicationProcessLogExceptionHandler exceptionHandler,
IReplicationInFacade replicationInFacade,
String name,
String groupName,
String sourceLookupName,
IReplicationGroupHistory groupHistory) |
MultiBucketSingleFileSyncTargetProcessLog(ProcessLogConfig config,
IReplicationPacketDataConsumer dataConsumer,
IReplicationProcessLogExceptionHandler exceptionHandler,
IReplicationInFacade replicationInFacade,
String name,
String groupName,
String sourceLookupName,
long[] lastProcessedKeys,
long[] lastGlobalProcessedKeys,
boolean firstHandshakeForTarget,
IReplicationGroupHistory groupHistory) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
contentRequiredWhileProcessing() |
afterSuccessfulConsumption, canResetState, close, createBatchParallelProcessingContinuationTask, dumpState, dumpStateExtra, getConsumeTimeout, getExecutorService, getLastGlobalProcessedKeys, getLastProcessedKeys, getSpecificLogger, isFirstHandshakeForTarget, performHandshake, process, process, process, process, process, process, processBatch, processHandshakeIteration, processIdleStateData, resync, shouldCloneOnFilter, throwClosedException, toWireForm, validateNotClosed, validateOpencreateReplicationInContext, getDataConsumer, getExceptionHandler, getGroupHistory, getGroupName, getReplicationInContext, getReplicationInFacade, getSourceLookupName, throwIfRepetitiveError, toLogMessageclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitclose, dumpState, getDataConsumer, performHandshake, process, processBatch, processHandshakeIteration, processIdleStateData, resync, toLogMessage, toWireFormpublic MultiBucketSingleFileSyncTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory)
public MultiBucketSingleFileSyncTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataConsumer dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long[] lastProcessedKeys, long[] lastGlobalProcessedKeys, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory)
protected boolean contentRequiredWhileProcessing()
contentRequiredWhileProcessing in class AbstractSingleFileTargetProcessLogCopyright © GigaSpaces.