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

Packages that use IReplicationPacketDataConsumer

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 IReplicationPacketDataConsumer in com.gigaspaces.internal.cluster.node.impl.packets.data

Subinterfaces of IReplicationPacketDataConsumer in com.gigaspaces.internal.cluster.node.impl.packets.data

Modifier and Type	Interface and Description
interface	IReplicationPacketDataBatchConsumer<T extends IReplicationPacketData<?>>

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

Modifier and Type	Class and Description
class	BlobstoreReplicationPacketDataConsumer
class	ReplicationPacketDataConsumer

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

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

Modifier and Type	Field and Description
protected IReplicationPacketDataConsumer	AbstractSingleFileTargetProcessLog._dataConsumer

Methods in com.gigaspaces.internal.cluster.node.impl.processlog that return IReplicationPacketDataConsumer

Modifier and Type	Method and Description
<T extends IReplicationPacketData<?>> IReplicationPacketDataConsumer<T>	IReplicationTargetProcessLog.getDataConsumer()
<T extends IReplicationPacketData<?>> IReplicationPacketDataConsumer<T>	AbstractSingleFileTargetProcessLog.getDataConsumer()

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

Constructor and Description
AbstractSingleFileTargetProcessLog(IReplicationPacketDataConsumer dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory)

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

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

Constructor and Description
AbstractGlobalOrderTargetProcessLog(IReplicationPacketDataConsumer dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastProcessedKey, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory)
GlobalOrderReliableAsyncTargetKeeperProcessLog(GlobalOrderProcessLogConfig processLogConfig, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, boolean oneWayMode, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator)
GlobalOrderReliableAsyncTargetKeeperProcessLog(GlobalOrderProcessLogConfig processLogConfig, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastProcessedKey, boolean isFirstHandshake, boolean oneWayMode, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator)
GlobalOrderTargetProcessLog(GlobalOrderProcessLogConfig processLogConfig, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, boolean oneWayProcessing, IReplicationGroupHistory groupHistory)
GlobalOrderTargetProcessLog(GlobalOrderProcessLogConfig processLogConfig, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastProcessedKey, boolean isFirstHandshake, boolean oneWayProcessing, IReplicationGroupHistory groupHistory)

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

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

Constructor and Description
AbstractMultiBucketSingleFileTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory)
AbstractMultiBucketSingleFileTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long[] lastProcessedKeys, long[] lastGlobalProcessedKeys, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory)
MultiBucketSingleFileReliableAsyncTargetKeeperProcessLog(ProcessLogConfig config, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator)
MultiBucketSingleFileReliableAsyncTargetKeeperProcessLog(ProcessLogConfig config, IReplicationPacketDataConsumer dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long[] lastProcessedKeys, long[] lastGlobalProcessedKeys, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator)
MultiBucketSingleFileSyncTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory)
MultiBucketSingleFileSyncTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataConsumer dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long[] lastProcessedKeys, long[] lastGlobalProcessedKeys, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory)

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

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

Constructor and Description
MultiSourceSingleFileReliableAsyncTargetKeeperProcessLog(MultiSourceSingleFileProcessLogConfig processLogConfig, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, boolean oneWayMode, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator)
MultiSourceSingleFileReliableAsyncTargetKeeperProcessLog(MultiSourceSingleFileProcessLogConfig processLogConfig, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastProcessedKey, boolean isFirstHandshake, boolean oneWayMode, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator)