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

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

_dataConsumer, _specificLogger

Constructor Summary

Constructors

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

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

Constructor Detail

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 Detail

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