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

Class MultiBucketSingleFileReplicationInBatchContext

java.lang.Object

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

com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile.MultiBucketSingleFileReplicationInBatchContext

All Implemented Interfaces:

IReplicationInBatchContext, IReplicationInContext

public class MultiBucketSingleFileReplicationInBatchContext
extends ReplicationInContext
implements IReplicationInBatchContext

Constructor Summary

Constructors

Constructor and Description
MultiBucketSingleFileReplicationInBatchContext(IBatchExecutedCallback batchExecutedCallback, String sourceLookupName, String groupName, Logger contextLogger, int entireBatchSize)

Method Summary

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

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

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

Constructor Detail

MultiBucketSingleFileReplicationInBatchContext

public MultiBucketSingleFileReplicationInBatchContext(IBatchExecutedCallback batchExecutedCallback,
                                                      String sourceLookupName,
                                                      String groupName,
                                                      Logger contextLogger,
                                                      int entireBatchSize)

Method Detail

pendingConsumed

public void pendingConsumed()

Description copied from interface: IReplicationInBatchContext

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

Specified by:

pendingConsumed in interface IReplicationInBatchContext

addPendingContext

public <T> void addPendingContext(T operationContext)

Specified by:

addPendingContext in interface IReplicationInBatchContext

updatePendingProcessedKeys

public void updatePendingProcessedKeys()

getPendingContext

public <T> List<T> getPendingContext()

Specified by:

getPendingContext in interface IReplicationInBatchContext

setCurrentPacket

public void setCurrentPacket(IMultiBucketSingleFileReplicationOrderedPacket packet)

currentConsumed

public void currentConsumed()

Specified by:

currentConsumed in interface IReplicationInBatchContext

setTagObject

public <T> void setTagObject(T tagObject)

Specified by:

setTagObject in interface IReplicationInBatchContext

getTagObject

public <T> T getTagObject()

Specified by:

getTagObject in interface IReplicationInBatchContext

getEntireBatchSize

public int getEntireBatchSize()

Specified by:

getEntireBatchSize in interface IReplicationInBatchContext

snapshot

public void snapshot()

rollback

public void rollback()

isBatchContext

public boolean isBatchContext()

Specified by:

isBatchContext in interface IReplicationInContext

Overrides:

isBatchContext in class ReplicationInContext