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

Class MultiSourceSingleFileReplicationInBatchContext

java.lang.Object

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

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

com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile.MultiSourceSingleFileReplicationInBatchContext

All Implemented Interfaces:

IReplicationInBatchContext, IReplicationInContext

public class MultiSourceSingleFileReplicationInBatchContext
extends AbstractReplicationInBatchContext

Since:

8.0.4

Author:

idan, eitan

Constructor Summary

Constructors

Constructor and Description
MultiSourceSingleFileReplicationInBatchContext(IPacketConsumedCallback packetConsumedCallback, org.slf4j.Logger contextLogger, int entireBatchSize, IReplicationParticipantsMediator participantsMediator, String sourceLookupName, String groupName)

Method Summary

Modifier and Type	Method and Description
void	addBeingConsumedPacket(MultiSourceProcessLogPacket packet)
protected void	afterBatchConsumed(long lastProcessedKeyInBatch)
List<MultiSourceProcessLogPacket>	getBeingConsumedPackets()
boolean	isBatchContext()
void	rollback()

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

addPendingContext, currentConsumed, getCurrentKey, getEntireBatchSize, getPendingContext, getTagObject, pendingConsumed, 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.IReplicationInContext

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

Constructor Detail

MultiSourceSingleFileReplicationInBatchContext

public MultiSourceSingleFileReplicationInBatchContext(IPacketConsumedCallback packetConsumedCallback,
                                                      org.slf4j.Logger contextLogger,
                                                      int entireBatchSize,
                                                      IReplicationParticipantsMediator participantsMediator,
                                                      String sourceLookupName,
                                                      String groupName)

Method Detail

addBeingConsumedPacket

public void addBeingConsumedPacket(MultiSourceProcessLogPacket packet)

afterBatchConsumed

protected void afterBatchConsumed(long lastProcessedKeyInBatch)

Specified by:

afterBatchConsumed in class AbstractReplicationInBatchContext

rollback

public void rollback()

Overrides:

rollback in class AbstractReplicationInBatchContext

isBatchContext

public boolean isBatchContext()

Specified by:

isBatchContext in interface IReplicationInContext

Overrides:

isBatchContext in class AbstractReplicationInBatchContext

getBeingConsumedPackets

public List<MultiSourceProcessLogPacket> getBeingConsumedPackets()