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

Class GlobalOrderReplicationInBatchContext

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.ReplicationInContext

com.gigaspaces.internal.cluster.node.impl.AbstractReplicationInBatchContext

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

All Implemented Interfaces:

IReplicationInBatchContext, IReplicationInContext

public class GlobalOrderReplicationInBatchContext
extends AbstractReplicationInBatchContext
implements IReplicationInBatchContext

Constructor Summary

Constructors

Constructor and Description
GlobalOrderReplicationInBatchContext(IBatchExecutedCallback batchExecutedCallback, org.slf4j.Logger contextLogger, int entireBatchSize, String sourceLookupName, String groupName)

Method Summary

Modifier and Type	Method and Description
protected void	afterBatchConsumed(long lastProcessedKeyInBatch)

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.AbstractReplicationInBatchContext

addPendingContext, currentConsumed, getCurrentKey, getEntireBatchSize, getPendingContext, getTagObject, isBatchContext, pendingConsumed, rollback, setCurrentKey, setTagObject, snapshot

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.ReplicationInContext

getContentContext, getContextLogger, getContextMarker, getGroupName, getLastProcessedKey, getReplicationBlobstoreBulkContext, getSourceLookupName, setContextPacket, setLastProcessedKey, setReplicationBlobstoreBulkContext, supportsDistributedTransactionConsolidation

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

addPendingContext, currentConsumed, getEntireBatchSize, getPendingContext, getTagObject, pendingConsumed, setTagObject

Methods inherited from interface com.gigaspaces.internal.cluster.node.IReplicationInContext

getContentContext, getContextLogger, getContextMarker, getGroupName, getLastProcessedKey, getReplicationBlobstoreBulkContext, getSourceLookupName, isBatchContext, setReplicationBlobstoreBulkContext, supportsDistributedTransactionConsolidation

Constructor Detail

GlobalOrderReplicationInBatchContext

public GlobalOrderReplicationInBatchContext(IBatchExecutedCallback batchExecutedCallback,
                                            org.slf4j.Logger contextLogger,
                                            int entireBatchSize,
                                            String sourceLookupName,
                                            String groupName)

Method Detail

afterBatchConsumed

protected void afterBatchConsumed(long lastProcessedKeyInBatch)

Specified by:

afterBatchConsumed in class AbstractReplicationInBatchContext