Class MultiSourceSingleFileReliableAsyncTargetKeeperProcessLog

java.lang.Object

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

com.gigaspaces.internal.cluster.node.impl.processlog.globalorder.AbstractGlobalOrderTargetProcessLog

com.gigaspaces.internal.cluster.node.impl.processlog.globalorder.GlobalOrderTargetProcessLog

com.gigaspaces.internal.cluster.node.impl.processlog.globalorder.GlobalOrderReliableAsyncTargetKeeperProcessLog

com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile.MultiSourceSingleFileReliableAsyncTargetKeeperProcessLog

All Implemented Interfaces:

IReplicationAsyncTargetProcessLog, IReplicationTargetProcessLog, IReplicationReliableAsyncKeeperTargetProcessLog, IReplicationSyncTargetProcessLog

public class MultiSourceSingleFileReliableAsyncTargetKeeperProcessLog
extends GlobalOrderReliableAsyncTargetKeeperProcessLog

Nested Class Summary

Nested classes/interfaces inherited from class GlobalOrderTargetProcessLog

GlobalOrderTargetProcessLog.SharedOrderedPacketComparator

Field Summary

Fields inherited from class AbstractGlobalOrderTargetProcessLog

_lastProcessedKey, _lifeCycleLock, _lock

Fields inherited from class AbstractSingleFileTargetProcessLog

_dataConsumer, _specificLogger

Constructor Summary

Constructors

Constructor	Description
MultiSourceSingleFileReliableAsyncTargetKeeperProcessLog(MultiSourceSingleFileProcessLogConfig processLogConfig, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, boolean oneWayMode, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator)
MultiSourceSingleFileReliableAsyncTargetKeeperProcessLog(MultiSourceSingleFileProcessLogConfig processLogConfig, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastProcessedKey, boolean isFirstHandshake, boolean oneWayMode, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator)

Method Summary

Modifier and Type	Method	Description
protected IReliableAsyncState	getReliableAsyncStateFromHandshakeRequest(IBacklogHandshakeRequest handshakeRequest)

Methods inherited from class GlobalOrderReliableAsyncTargetKeeperProcessLog

afterSuccessfulConsumption, canResetState, contentRequiredWhileProcessing, createReplicationInContext, getMediator, getReplicationInContext, performHandshake, processHandshakeIteration, shouldCloneOnFilter

Methods inherited from class GlobalOrderTargetProcessLog

dumpStateExtra, onClose, process, processBatch, processPackets

Methods inherited from class AbstractGlobalOrderTargetProcessLog

close, dumpState, filterDuplicate, filterDuplicate, getLastProcessedKey, isClosed, isFirstHandshakeForTarget, isOpen, logDeletion, processIdleStateData, resync, throwClosedException, toWireForm

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, processIdleStateData, resync, toLogMessage, toWireForm

Constructor Details

MultiSourceSingleFileReliableAsyncTargetKeeperProcessLog

public MultiSourceSingleFileReliableAsyncTargetKeeperProcessLog(MultiSourceSingleFileProcessLogConfig processLogConfig,
 IReplicationPacketDataConsumer<?> dataConsumer,
 IReplicationProcessLogExceptionHandler exceptionHandler,
 IReplicationInFacade replicationInFacade,
 String name,
 String groupName,
 String sourceLookupName,
 boolean oneWayMode,
 IReplicationGroupHistory groupHistory,
 IReplicationReliableAsyncMediator mediator)

MultiSourceSingleFileReliableAsyncTargetKeeperProcessLog

public MultiSourceSingleFileReliableAsyncTargetKeeperProcessLog(MultiSourceSingleFileProcessLogConfig processLogConfig,
 IReplicationPacketDataConsumer<?> dataConsumer,
 IReplicationProcessLogExceptionHandler exceptionHandler,
 IReplicationInFacade replicationInFacade,
 String name,
 String groupName,
 String sourceLookupName,
 long lastProcessedKey,
 boolean isFirstHandshake,
 boolean oneWayMode,
 IReplicationGroupHistory groupHistory,
 IReplicationReliableAsyncMediator mediator)

Method Details

getReliableAsyncStateFromHandshakeRequest

protected IReliableAsyncState getReliableAsyncStateFromHandshakeRequest(IBacklogHandshakeRequest handshakeRequest)

Overrides:

getReliableAsyncStateFromHandshakeRequest in class GlobalOrderReliableAsyncTargetKeeperProcessLog