Uses of Interface
com.gigaspaces.internal.cluster.node.impl.packets.data.IReplicationPacketDataBatchConsumer

Packages that use IReplicationPacketDataBatchConsumer

Package	Description
com.gigaspaces.internal.cluster.node.impl.packets.data
com.gigaspaces.internal.cluster.node.impl.processlog
com.gigaspaces.internal.cluster.node.impl.processlog.globalorder
com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile
com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile

Uses of IReplicationPacketDataBatchConsumer in com.gigaspaces.internal.cluster.node.impl.packets.data

Classes in com.gigaspaces.internal.cluster.node.impl.packets.data that implement IReplicationPacketDataBatchConsumer

Modifier and Type	Class and Description
class	BlobstoreReplicationPacketDataConsumer
class	ReplicationPacketDataConsumer

Uses of IReplicationPacketDataBatchConsumer in com.gigaspaces.internal.cluster.node.impl.processlog

Constructors in com.gigaspaces.internal.cluster.node.impl.processlog with parameters of type IReplicationPacketDataBatchConsumer

Constructor and Description
ReliableAsyncAdaptiveProcessLogBuilder(IReplicationPacketDataBatchConsumer<?> dataConsumer, DistributedTransactionProcessingConfiguration distributedTransactionProcessingConfiguration)

Uses of IReplicationPacketDataBatchConsumer in com.gigaspaces.internal.cluster.node.impl.processlog.globalorder

Fields in com.gigaspaces.internal.cluster.node.impl.processlog.globalorder declared as IReplicationPacketDataBatchConsumer

Modifier and Type	Field and Description
protected IReplicationPacketDataBatchConsumer<?>	GlobalOrderProcessLogBuilder._dataConsumer

Constructors in com.gigaspaces.internal.cluster.node.impl.processlog.globalorder with parameters of type IReplicationPacketDataBatchConsumer

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

Uses of IReplicationPacketDataBatchConsumer in com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile

Constructors in com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile with parameters of type IReplicationPacketDataBatchConsumer

Constructor and Description
MultiBucketSingleFileBatchConsumeTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory)
MultiBucketSingleFileBatchConsumeTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastGlobalProcessedKey, long[] lastProcessedKeys, long[] lastGlobalProcessedKeys, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory)
MultiBucketSingleFileProcessLogBuilder(IReplicationPacketDataBatchConsumer<?> dataConsumer)
MultiBucketSingleFileReliableAsyncTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory)
MultiBucketSingleFileReliableAsyncTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastGlobalProcessedKey, long[] lastProcessedKeys, long[] lastGlobalProcessedKeys, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory)

Uses of IReplicationPacketDataBatchConsumer in com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile

Constructors in com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile with parameters of type IReplicationPacketDataBatchConsumer

Constructor and Description
MultiSourceSingleFileProcessLogBuilder(IReplicationPacketDataBatchConsumer<?> dataConsumer)
MultiSourceSingleFileReliableAsyncTargetProcessLog(MultiSourceSingleFileProcessLogConfig processLogConfig, IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory, IReplicationParticipantsMediator participantsMediator, IProcessMemoryManager processMemoryManager)
MultiSourceSingleFileReliableAsyncTargetProcessLog(MultiSourceSingleFileProcessLogConfig processLogConfig, IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String myLookupName, String groupName, String sourceLookupName, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory, IReplicationParticipantsMediator participantsMediator, long lastProcessedKey, long firstUnprocessedKey, LinkedList<MultiSourceProcessLogPacket> pendingPacketsQueue, HashMap<String,MultiSourceProcessLogPacket> packetsByUidHelperMap, IProcessMemoryManager processMemoryManager)