com.gigaspaces.internal.cluster.node.impl.replica

Class SpaceReplicaDataConsumer

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.replica.SpaceReplicaDataConsumer

All Implemented Interfaces:

ISpaceReplicaDataConsumer<IExecutableSpaceReplicaData,SpaceCopyIntermediateResult>

public class SpaceReplicaDataConsumer
extends Object
implements ISpaceReplicaDataConsumer<IExecutableSpaceReplicaData,SpaceCopyIntermediateResult>

Constructor Summary

Constructors

Constructor and Description
SpaceReplicaDataConsumer(SpaceTypeManager typeManager, ISpaceReplicaConsumeFacade consumeFacade)

Method Summary

Modifier and Type	Method and Description
void	consumeData(IExecutableSpaceReplicaData data, SpaceCopyIntermediateResult intermediateResult, IIncomingReplicationFacade facade) consumes one ISpaceReplicaData.
SpaceCopyIntermediateResult	createEmptyResult()
IReplicationFilterEntry	toFilterEntry(IExecutableSpaceReplicaData data)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SpaceReplicaDataConsumer

public SpaceReplicaDataConsumer(SpaceTypeManager typeManager,
                                ISpaceReplicaConsumeFacade consumeFacade)

Method Detail

consumeData

public void consumeData(IExecutableSpaceReplicaData data,
                        SpaceCopyIntermediateResult intermediateResult,
                        IIncomingReplicationFacade facade)
                 throws Exception

Description copied from interface: ISpaceReplicaDataConsumer

consumes one ISpaceReplicaData.

Specified by:

consumeData in interface ISpaceReplicaDataConsumer<IExecutableSpaceReplicaData,SpaceCopyIntermediateResult>

Parameters:

data - to consume

Throws:

Exception

createEmptyResult

public SpaceCopyIntermediateResult createEmptyResult()

Specified by:

createEmptyResult in interface ISpaceReplicaDataConsumer<IExecutableSpaceReplicaData,SpaceCopyIntermediateResult>

toFilterEntry

public IReplicationFilterEntry toFilterEntry(IExecutableSpaceReplicaData data)

Specified by:

toFilterEntry in interface ISpaceReplicaDataConsumer<IExecutableSpaceReplicaData,SpaceCopyIntermediateResult>