Class MultiBucketSingleFileReliableAsyncTargetProcessLog

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.processlog.AbstractSingleFileTargetProcessLog

com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile.AbstractMultiBucketSingleFileTargetProcessLog

com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile.MultiBucketSingleFileBatchConsumeTargetProcessLog

com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile.MultiBucketSingleFileReliableAsyncTargetProcessLog

All Implemented Interfaces:

IReplicationAsyncTargetProcessLog, IReplicationBatchConsumeAsyncTargetProcessLog, IReplicationTargetProcessLog, IBatchExecutedCallback, IMultiBucketSingleFileProcessLog, IReplicationReliableAsyncTargetProcessLog

public class MultiBucketSingleFileReliableAsyncTargetProcessLog
extends MultiBucketSingleFileBatchConsumeTargetProcessLog
implements IReplicationReliableAsyncTargetProcessLog

Field Summary

Fields inherited from class MultiBucketSingleFileBatchConsumeTargetProcessLog

_lock

Fields inherited from class AbstractSingleFileTargetProcessLog

_dataConsumer, _specificLogger

Constructor Summary

Constructors

Constructor	Description
MultiBucketSingleFileReliableAsyncTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastGlobalProcessedKey, long[] lastProcessedKeys, long[] lastGlobalProcessedKeys, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory)
MultiBucketSingleFileReliableAsyncTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory)

Method Summary

Methods inherited from class MultiBucketSingleFileBatchConsumeTargetProcessLog

batchConsumed, contentRequiredWhileProcessing, dumpStateExtra, filterDuplicate, filterDuplicate, getLastGlobalProcessedKey, performHandshake, process, processBatch

Methods inherited from class AbstractMultiBucketSingleFileTargetProcessLog

afterSuccessfulConsumption, canResetState, close, createBatchParallelProcessingContinuationTask, dumpState, getConsumeTimeout, getExecutorService, getLastGlobalProcessedKeys, getLastProcessedKeys, getSpecificLogger, isFirstHandshakeForTarget, process, process, process, process, process, processHandshakeIteration, processIdleStateData, resync, shouldCloneOnFilter, throwClosedException, toWireForm, validateNotClosed, validateOpen

Methods inherited from class AbstractSingleFileTargetProcessLog

createReplicationInContext, getDataConsumer, getExceptionHandler, getGroupHistory, getGroupName, getReplicationInContext, getReplicationInFacade, getSourceLookupName, throwIfRepetitiveError, toLogMessage

Methods inherited from class Object

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

Methods inherited from interface IReplicationTargetProcessLog

close, dumpState, getDataConsumer, performHandshake, process, processBatch, processHandshakeIteration, processIdleStateData, resync, toLogMessage, toWireForm

Constructor Details

MultiBucketSingleFileReliableAsyncTargetProcessLog

public MultiBucketSingleFileReliableAsyncTargetProcessLog(ProcessLogConfig config,
 IReplicationPacketDataBatchConsumer<?> dataConsumer,
 IReplicationProcessLogExceptionHandler exceptionHandler,
 IReplicationInFacade replicationInFacade,
 String name,
 String groupName,
 String sourceLookupName,
 IReplicationGroupHistory groupHistory)

MultiBucketSingleFileReliableAsyncTargetProcessLog

public MultiBucketSingleFileReliableAsyncTargetProcessLog(ProcessLogConfig config,
 IReplicationPacketDataBatchConsumer<?> dataConsumer,
 IReplicationProcessLogExceptionHandler exceptionHandler,
 IReplicationInFacade replicationInFacade,
 String name,
 String groupName,
 String sourceLookupName,
 long lastGlobalProcessedKey,
 long[] lastProcessedKeys,
 long[] lastGlobalProcessedKeys,
 boolean firstHandshakeForTarget,
 IReplicationGroupHistory groupHistory)