Uses of Interface
com.gigaspaces.internal.cluster.node.impl.filters.IReplicationInFilterCallback

Packages that use IReplicationInFilterCallback

Package	Description
com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile
com.gigaspaces.internal.cluster.node.impl.groups
com.gigaspaces.internal.cluster.node.impl.groups.async
com.gigaspaces.internal.cluster.node.impl.groups.sync
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 IReplicationInFilterCallback in com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile

Methods in com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile with parameters of type IReplicationInFilterCallback

Modifier and Type	Method and Description
MultiBucketSingleFileProcessResult	MultiBucketSingleFileReliableAsyncKeptDiscardedPacket.process(String sourceLookupName, IMultiBucketSingleFileProcessLog processLog, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext context, int segmentIndex)
MultiBucketSingleFileProcessResult	SingleBucketOrderedPacket.process(String sourceLookupName, IMultiBucketSingleFileProcessLog processLog, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext context, int segmentIndex)
MultiBucketSingleFileProcessResult	MultipleBucketOrderedPacket.process(String sourceLookupName, IMultiBucketSingleFileProcessLog processLog, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext context, int segmentIndex)
MultiBucketSingleFileProcessResult	DeletedMultiBucketOrderedPacket.process(String sourceLookupName, IMultiBucketSingleFileProcessLog processLog, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext context, int segmentIndex)
MultiBucketSingleFileProcessResult	DiscardedMultiBucketOrderedPacket.process(String sourceLookupName, IMultiBucketSingleFileProcessLog processLog, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext context, int segmentIndex)
MultiBucketSingleFileProcessResult	IMultiBucketSingleFileReplicationOrderedPacket.process(String sourceLookupName, IMultiBucketSingleFileProcessLog processLog, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext context, int segmentIndex)
MultiBucketSingleFileProcessResult	DiscardedSingleBucketOrderedPacket.process(String sourceLookupName, IMultiBucketSingleFileProcessLog processLog, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext context, int segmentIndex)

Uses of IReplicationInFilterCallback in com.gigaspaces.internal.cluster.node.impl.groups

Classes in com.gigaspaces.internal.cluster.node.impl.groups that implement IReplicationInFilterCallback

Modifier and Type	Class and Description
class	AbstractReplicationTargetChannel

Uses of IReplicationInFilterCallback in com.gigaspaces.internal.cluster.node.impl.groups.async

Classes in com.gigaspaces.internal.cluster.node.impl.groups.async that implement IReplicationInFilterCallback

Modifier and Type	Class and Description
class	AsyncReplicationTargetChannel

Uses of IReplicationInFilterCallback in com.gigaspaces.internal.cluster.node.impl.groups.sync

Classes in com.gigaspaces.internal.cluster.node.impl.groups.sync that implement IReplicationInFilterCallback

Modifier and Type	Class and Description
class	SyncReplicationTargetChannel

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

Methods in com.gigaspaces.internal.cluster.node.impl.packets.data with parameters of type IReplicationInFilterCallback

Modifier and Type	Method and Description
IDataConsumeResult	ReplicationPacketDataConsumer.consume(IReplicationInContext context, IExecutableReplicationPacketData<?> data, IReplicationInFacade replicationInFacade, IReplicationInFilterCallback inFilterCallback)
IDataConsumeResult	BlobstoreReplicationPacketDataConsumer.consume(IReplicationInContext context, IExecutableReplicationPacketData<?> data, IReplicationInFacade replicationInFacade, IReplicationInFilterCallback inFilterCallback)
IDataConsumeResult	IReplicationPacketDataConsumer.consume(IReplicationInContext context, T data, IReplicationInFacade replicationInFacade, IReplicationInFilterCallback filterInCallback) Consumes a IReplicationPacketData and delegate the operation is represents to the corresponding method at the given IReplicationInFacade

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

Methods in com.gigaspaces.internal.cluster.node.impl.processlog with parameters of type IReplicationInFilterCallback

Modifier and Type	Method and Description
IProcessResult	IReplicationTargetProcessLog.process(String sourceLookupName, IReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback)
IProcessResult	IReplicationTargetProcessLog.processBatch(String sourceLookupName, List<IReplicationOrderedPacket> packet, IReplicationInFilterCallback inFilterCallback)
IProcessResult	IReplicationTargetProcessLog.processIdleStateData(String sourceLookupName, IIdleStateData idleStateData, IReplicationInFilterCallback inFilterCallback)

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

Methods in com.gigaspaces.internal.cluster.node.impl.processlog.globalorder with parameters of type IReplicationInFilterCallback

Modifier and Type	Method and Description
GlobalOrderProcessResult	GlobalOrderTargetProcessLog.process(String sourceLookupName, IReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback)
IProcessResult	GlobalOrderBatchConsumeTargetProcessLog.process(String sourceLookupName, IReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback)
GlobalOrderProcessResult	GlobalOrderTargetProcessLog.processBatch(String sourceLookupName, List<IReplicationOrderedPacket> packets, IReplicationInFilterCallback filterInCallback)
GlobalOrderProcessResult	GlobalOrderBatchConsumeTargetProcessLog.processBatch(String sourceLookupName, List<IReplicationOrderedPacket> packets, IReplicationInFilterCallback inFilterCallback)
IProcessResult	AbstractGlobalOrderTargetProcessLog.processIdleStateData(String string, IIdleStateData idleStateData, IReplicationInFilterCallback inFilterCallback)
protected boolean	GlobalOrderTargetProcessLog.processPackets(String sourceLookupName, long myLastKey, IReplicationInFilterCallback filterInCallback)

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

Methods in com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile with parameters of type IReplicationInFilterCallback

Modifier and Type	Method and Description
MultiBucketSingleFileProcessResult	ProcessLogBucket.addAndProcess(String sourceLookupName, IMultiBucketSingleFileReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext batchContext, int segmentIndex)
void	AbstractMultiBucketSingleFileTargetProcessLog.createBatchParallelProcessingContinuationTask(String sourceLookupName, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext context, List<IReplicationOrderedPacket> batch, int segmentIndex)
MultiBucketSingleFileProcessResult	IMultiBucketSingleFileProcessLog.process(String sourceLookupName, DeletedMultiBucketOrderedPacket packet, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext batchContext, int segmentIndex)
MultiBucketSingleFileProcessResult	AbstractMultiBucketSingleFileTargetProcessLog.process(String sourceLookupName, DeletedMultiBucketOrderedPacket packet, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext batchContext, int segmentIndex)
MultiBucketSingleFileProcessResult	IMultiBucketSingleFileProcessLog.process(String sourceLookupName, DiscardedMultiBucketOrderedPacket packet, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext batchContext, int segmentIndex)
MultiBucketSingleFileProcessResult	AbstractMultiBucketSingleFileTargetProcessLog.process(String sourceLookupName, DiscardedMultiBucketOrderedPacket packet, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext batchContext, int segmentIndex)
MultiBucketSingleFileProcessResult	MultiBucketSingleFileBatchConsumeTargetProcessLog.process(String sourceLookupName, IReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback)
MultiBucketSingleFileProcessResult	AbstractMultiBucketSingleFileTargetProcessLog.process(String sourceLookupName, IReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback)
MultiBucketSingleFileProcessResult	AbstractMultiBucketSingleFileTargetProcessLog.process(String sourceLookupName, IReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext batchContext, int segmentIndex)
MultiBucketSingleFileProcessResult	IMultiBucketSingleFileProcessLog.process(String sourceLookupName, ISingleBucketReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext batchContext, int segmentIndex)
MultiBucketSingleFileProcessResult	AbstractMultiBucketSingleFileTargetProcessLog.process(String sourceLookupName, ISingleBucketReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext batchContext, int segmentIndex)
Throwable	ProcessLogBucket.process(String sourceLookupName, List<IMultiBucketSingleFileReplicationOrderedPacket> bucketPackets, IReplicationInFilterCallback inFilterCallback)
MultiBucketSingleFileProcessResult	IMultiBucketSingleFileProcessLog.process(String sourceLookupName, MultipleBucketOrderedPacket packet, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext batchContext, int segmentIndex)
MultiBucketSingleFileProcessResult	AbstractMultiBucketSingleFileTargetProcessLog.process(String sourceLookupName, MultipleBucketOrderedPacket packet, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext batchContext, int segmentIndex)
MultiBucketSingleFileProcessResult	MultiBucketSingleFileBatchConsumeTargetProcessLog.processBatch(String sourceLookupName, List<IReplicationOrderedPacket> packets, IReplicationInFilterCallback inFilterCallback)
MultiBucketSingleFileProcessResult	AbstractMultiBucketSingleFileTargetProcessLog.processBatch(String sourceLookupName, List<IReplicationOrderedPacket> packets, IReplicationInFilterCallback inFilterCallback)
IProcessResult	AbstractMultiBucketSingleFileTargetProcessLog.processIdleStateData(String string, IIdleStateData idleStateData, IReplicationInFilterCallback inFilterCallback)
void	ProcessLogBucket.signalDoneProcessing(String sourceLookupName, MultipleBucketOrderedPacket packet, IReplicationInFilterCallback inFilterCallback)

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

Methods in com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile with parameters of type IReplicationInFilterCallback

Modifier and Type	Method and Description
IProcessResult	MultiSourceSingleFileReliableAsyncTargetProcessLog.process(String sourceLookupName, IReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback)
IProcessResult	MultiSourceSingleFileReliableAsyncTargetProcessLog.processBatch(String sourceLookupName, List<IReplicationOrderedPacket> packets, IReplicationInFilterCallback inFilterCallback)
IProcessResult	MultiSourceSingleFileReliableAsyncTargetProcessLog.processIdleStateData(String sourceLookupName, IIdleStateData idleStateData, IReplicationInFilterCallback inFilterCallback)