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

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 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
GlobalOrderReliableAsyncTargetProcessLog(IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory)
GlobalOrderReliableAsyncTargetProcessLog(IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastProcessedKey, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory)

Method Summary

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

batchConsumed, contentRequiredWhileProcessing, onClose, process, processBatch

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

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

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

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

Constructor Detail

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)