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 and 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 and 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, getLogLevel, 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 Detail

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 Detail

getReliableAsyncStateFromHandshakeRequest

protected IReliableAsyncState getReliableAsyncStateFromHandshakeRequest(IBacklogHandshakeRequest handshakeRequest)

Overrides:

getReliableAsyncStateFromHandshakeRequest in class GlobalOrderReliableAsyncTargetKeeperProcessLog