com.gigaspaces.internal.cluster.node

Interface IReplicationInBatchContext

All Superinterfaces:

IReplicationInContext

All Known Implementing Classes:

AbstractReplicationInBatchContext, GlobalOrderReplicationInBatchContext, MultiBucketSingleFileReplicationInBatchContext, MultiSourceSingleFileReplicationInBatchContext

public interface IReplicationInBatchContext
extends IReplicationInContext

Method Summary

Modifier and Type	Method and Description
<T> void	addPendingContext(T operationContext)
void	currentConsumed()
int	getEntireBatchSize()
<T> List<T>	getPendingContext()
<T> T	getTagObject()
void	pendingConsumed() Should be called once all the pending operation that are kept in the context are consumed and considered successfully replicated.
<T> void	setTagObject(T tagObject)

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

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

Method Detail

pendingConsumed

void pendingConsumed()

Should be called once all the pending operation that are kept in the context are consumed and considered successfully replicated. once called all the pending operations that are kept in the context are cleared

addPendingContext

<T> void addPendingContext(T operationContext)

getPendingContext

<T> List<T> getPendingContext()

currentConsumed

void currentConsumed()

setTagObject

<T> void setTagObject(T tagObject)

getTagObject

<T> T getTagObject()

getEntireBatchSize

int getEntireBatchSize()