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

Class MultiBucketSingleFileSyncTargetProcessLog

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.MultiBucketSingleFileSyncTargetProcessLog

All Implemented Interfaces:

IReplicationTargetProcessLog, IMultiBucketSingleFileProcessLog, IReplicationSyncTargetProcessLog

Direct Known Subclasses:

MultiBucketSingleFileReliableAsyncTargetKeeperProcessLog

public class MultiBucketSingleFileSyncTargetProcessLog
extends AbstractMultiBucketSingleFileTargetProcessLog
implements IReplicationSyncTargetProcessLog

Field Summary

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

_dataConsumer, _specificLogger

Constructor Summary

Constructors

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)

Method Summary

Modifier and Type	Method and Description
protected boolean	contentRequiredWhileProcessing()

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

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, validateOpen

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

createReplicationInContext, getDataConsumer, getExceptionHandler, getGroupHistory, getGroupName, getLogLevel, 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

MultiBucketSingleFileSyncTargetProcessLog

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

MultiBucketSingleFileSyncTargetProcessLog

public MultiBucketSingleFileSyncTargetProcessLog(ProcessLogConfig config,
                                                 IReplicationPacketDataConsumer dataConsumer,
                                                 IReplicationProcessLogExceptionHandler exceptionHandler,
                                                 IReplicationInFacade replicationInFacade,
                                                 String name,
                                                 String groupName,
                                                 String sourceLookupName,
                                                 long[] lastProcessedKeys,
                                                 long[] lastGlobalProcessedKeys,
                                                 boolean firstHandshakeForTarget,
                                                 IReplicationGroupHistory groupHistory)

Method Detail

contentRequiredWhileProcessing

protected boolean contentRequiredWhileProcessing()

Specified by:

contentRequiredWhileProcessing in class AbstractSingleFileTargetProcessLog