Class GlobalOrderReliableAsyncTargetProcessLog

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.GlobalOrderBatchConsumeTargetProcessLog

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

All Implemented Interfaces:

IReplicationAsyncTargetProcessLog, IReplicationBatchConsumeAsyncTargetProcessLog, IBatchExecutedCallback, IReplicationTargetProcessLog, IReplicationReliableAsyncTargetProcessLog

public class GlobalOrderReliableAsyncTargetProcessLog
extends GlobalOrderBatchConsumeTargetProcessLog
implements IReplicationReliableAsyncTargetProcessLog

Can be used as a reliable async target process log for a source that is working in batches and single threaded only

Since:

8.0

Author:

eitany

Field Summary

Fields inherited from class AbstractGlobalOrderTargetProcessLog

_lastProcessedKey, _lifeCycleLock, _lock

Fields inherited from class AbstractSingleFileTargetProcessLog

_dataConsumer, _specificLogger

Constructor Summary

Constructors

Constructor	Description
GlobalOrderReliableAsyncTargetProcessLog(IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastProcessedKey, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory)
GlobalOrderReliableAsyncTargetProcessLog(IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory)

Method Summary

Methods inherited from class GlobalOrderBatchConsumeTargetProcessLog

batchConsumed, contentRequiredWhileProcessing, onClose, process, processBatch

Methods inherited from class AbstractGlobalOrderTargetProcessLog

canResetState, close, dumpState, dumpStateExtra, filterDuplicate, filterDuplicate, getLastProcessedKey, isClosed, isFirstHandshakeForTarget, isOpen, logDeletion, performHandshake, processHandshakeIteration, processIdleStateData, resync, throwClosedException, toWireForm

Methods inherited from class AbstractSingleFileTargetProcessLog

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

Constructor Details

GlobalOrderReliableAsyncTargetProcessLog

public GlobalOrderReliableAsyncTargetProcessLog(IReplicationPacketDataBatchConsumer<?> dataConsumer,
 IReplicationProcessLogExceptionHandler exceptionHandler,
 IReplicationInFacade replicationInFacade,
 String name,
 String groupName,
 String sourceLookupName,
 long lastProcessedKey,
 boolean firstHandshakeForTarget,
 IReplicationGroupHistory groupHistory)

GlobalOrderReliableAsyncTargetProcessLog

public GlobalOrderReliableAsyncTargetProcessLog(IReplicationPacketDataBatchConsumer<?> dataConsumer,
 IReplicationProcessLogExceptionHandler exceptionHandler,
 IReplicationInFacade replicationInFacade,
 String name,
 String groupName,
 String sourceLookupName,
 IReplicationGroupHistory groupHistory)