Class MultiBucketSingleFileReliableAsyncTargetKeeperProcessLog

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

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

All Implemented Interfaces:

IReplicationTargetProcessLog, IMultiBucketSingleFileProcessLog, IReplicationReliableAsyncKeeperTargetProcessLog, IReplicationSyncTargetProcessLog

public class MultiBucketSingleFileReliableAsyncTargetKeeperProcessLog
extends MultiBucketSingleFileSyncTargetProcessLog
implements IReplicationReliableAsyncKeeperTargetProcessLog

Field Summary

Fields inherited from class AbstractSingleFileTargetProcessLog

_dataConsumer, _specificLogger

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected void	afterSuccessfulConsumption(String sourceLookupName, IReplicationOrderedPacket packet)
protected boolean	canResetState()
protected boolean	contentRequiredWhileProcessing()
ReplicationInContext	createReplicationInContext()
IReplicationReliableAsyncMediator	getMediator()
ReplicationInContext	getReplicationInContext()
MultiBucketSingleFileHandshakeResponse	performHandshake(String memberName, IBacklogHandshakeRequest handshakeRequest)
void	processHandshakeIteration(String sourceMemberName, IHandshakeIteration handshakeIteration)
protected boolean	shouldCloneOnFilter()

Methods inherited from class AbstractMultiBucketSingleFileTargetProcessLog

close, createBatchParallelProcessingContinuationTask, dumpState, dumpStateExtra, getConsumeTimeout, getExecutorService, getLastGlobalProcessedKeys, getLastProcessedKeys, getSpecificLogger, isFirstHandshakeForTarget, process, process, process, process, process, process, processBatch, processIdleStateData, resync, throwClosedException, toWireForm, validateNotClosed, validateOpen

Methods inherited from class AbstractSingleFileTargetProcessLog

getDataConsumer, getExceptionHandler, getGroupHistory, getGroupName, 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, process, processBatch, processIdleStateData, resync, toLogMessage, toWireForm

Constructor Details

MultiBucketSingleFileReliableAsyncTargetKeeperProcessLog

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

MultiBucketSingleFileReliableAsyncTargetKeeperProcessLog

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

Method Details

createReplicationInContext

public ReplicationInContext createReplicationInContext()

Overrides:

createReplicationInContext in class AbstractSingleFileTargetProcessLog

getReplicationInContext

public ReplicationInContext getReplicationInContext()

Overrides:

getReplicationInContext in class AbstractSingleFileTargetProcessLog

contentRequiredWhileProcessing

protected boolean contentRequiredWhileProcessing()

Overrides:

contentRequiredWhileProcessing in class MultiBucketSingleFileSyncTargetProcessLog

getMediator

public IReplicationReliableAsyncMediator getMediator()

Specified by:

getMediator in interface IReplicationReliableAsyncKeeperTargetProcessLog

shouldCloneOnFilter

protected boolean shouldCloneOnFilter()

Overrides:

shouldCloneOnFilter in class AbstractMultiBucketSingleFileTargetProcessLog

afterSuccessfulConsumption

protected void afterSuccessfulConsumption(String sourceLookupName,
 IReplicationOrderedPacket packet)

Overrides:

afterSuccessfulConsumption in class AbstractMultiBucketSingleFileTargetProcessLog

processHandshakeIteration

public void processHandshakeIteration(String sourceMemberName,
 IHandshakeIteration handshakeIteration)

Specified by:

processHandshakeIteration in interface IReplicationTargetProcessLog

Overrides:

processHandshakeIteration in class AbstractMultiBucketSingleFileTargetProcessLog

performHandshake

public MultiBucketSingleFileHandshakeResponse performHandshake(String memberName,
 IBacklogHandshakeRequest handshakeRequest)
                                                        throws IncomingReplicationOutOfSyncException

Specified by:

performHandshake in interface IReplicationTargetProcessLog

Overrides:

performHandshake in class AbstractMultiBucketSingleFileTargetProcessLog

Throws:

IncomingReplicationOutOfSyncException

canResetState

protected boolean canResetState()

Overrides:

canResetState in class AbstractMultiBucketSingleFileTargetProcessLog