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

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 com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile.MultiBucketSingleFileBatchConsumeTargetProcessLog

_lock

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.processlog.AbstractSingleFileTargetProcessLog

_dataConsumer, _specificLogger

Constructor Summary

Constructors

Constructor and Description
MultiBucketSingleFileReliableAsyncTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory)
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)

Method Summary

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile.MultiBucketSingleFileBatchConsumeTargetProcessLog

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

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile.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 com.gigaspaces.internal.cluster.node.impl.processlog.AbstractSingleFileTargetProcessLog

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.internal.cluster.node.impl.processlog.IReplicationTargetProcessLog

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

Constructor Detail

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)