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

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

GlobalOrderTargetProcessLog.SharedOrderedPacketComparator

Field Summary

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

_lastProcessedKey, _lifeCycleLock, _lock

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.processlog.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 com.gigaspaces.internal.cluster.node.impl.processlog.globalorder.GlobalOrderReliableAsyncTargetKeeperProcessLog

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

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

dumpStateExtra, onClose, process, processBatch, processPackets

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

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

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