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

Class GlobalOrderBatchConsumeTargetProcessLog

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

All Implemented Interfaces:

IReplicationAsyncTargetProcessLog, IReplicationBatchConsumeAsyncTargetProcessLog, IBatchExecutedCallback, IReplicationTargetProcessLog

Direct Known Subclasses:

GlobalOrderReliableAsyncTargetProcessLog

public class GlobalOrderBatchConsumeTargetProcessLog
extends AbstractGlobalOrderTargetProcessLog
implements IReplicationBatchConsumeAsyncTargetProcessLog, IBatchExecutedCallback

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

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

Method Summary

Modifier and Type	Method and Description
void	batchConsumed(long lastProcessKeyInBatch)
protected boolean	contentRequiredWhileProcessing()
protected void	onClose()
IProcessResult	process(String sourceLookupName, IReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback)
GlobalOrderProcessResult	processBatch(String sourceLookupName, List<IReplicationOrderedPacket> packets, IReplicationInFilterCallback inFilterCallback)

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

Constructor Detail

GlobalOrderBatchConsumeTargetProcessLog

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

GlobalOrderBatchConsumeTargetProcessLog

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

Method Detail

contentRequiredWhileProcessing

protected boolean contentRequiredWhileProcessing()

Specified by:

contentRequiredWhileProcessing in class AbstractSingleFileTargetProcessLog

onClose

protected void onClose()

Specified by:

onClose in class AbstractGlobalOrderTargetProcessLog

processBatch

public GlobalOrderProcessResult processBatch(String sourceLookupName,
                                             List<IReplicationOrderedPacket> packets,
                                             IReplicationInFilterCallback inFilterCallback)

Specified by:

processBatch in interface IReplicationTargetProcessLog

process

public IProcessResult process(String sourceLookupName,
                              IReplicationOrderedPacket packet,
                              IReplicationInFilterCallback inFilterCallback)

Specified by:

process in interface IReplicationTargetProcessLog

batchConsumed

public void batchConsumed(long lastProcessKeyInBatch)

Specified by:

batchConsumed in interface IBatchExecutedCallback