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

Class SpaceCopyReplicaDataProducer

java.lang.Object

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

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

All Implemented Interfaces:

ISingleStageReplicaDataProducer<IExecutableSpaceReplicaData>, ISpaceReplicaDataProducer<IExecutableSpaceReplicaData>

public class SpaceCopyReplicaDataProducer
extends AbstractMultiSpaceReplicaDataProducer

Nested Class Summary

Nested classes/interfaces inherited from interface com.gigaspaces.internal.cluster.node.impl.replica.ISingleStageReplicaDataProducer

ISingleStageReplicaDataProducer.CloseStatus

Field Summary

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.replica.AbstractMultiSpaceReplicaDataProducer

_engine, _logger, _requestContext

Fields inherited from interface com.gigaspaces.internal.cluster.node.impl.replica.ISingleStageReplicaDataProducer

FORCED_CLOSE_WAIT_TIME

Constructor Summary

Constructors

Constructor	Description
SpaceCopyReplicaDataProducer(SpaceEngine engine, SpaceCopyReplicaParameters parameters, Object requestContext)

Method Summary

Modifier and Type	Method	Description
protected List<ISingleStageReplicaDataProducer<? extends IExecutableSpaceReplicaData>>	buildDataProducers(SpaceCopyReplicaParameters parameters)
String	getName()
IReplicationFilterEntry	toFilterEntry(IExecutableSpaceReplicaData data)

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.replica.AbstractMultiSpaceReplicaDataProducer

close, dumpState, getLogPrefix, nextReplicaStage, onClose, produceNextData

Methods inherited from class java.lang.Object

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

Constructor Details

SpaceCopyReplicaDataProducer

public SpaceCopyReplicaDataProducer(SpaceEngine engine,
 SpaceCopyReplicaParameters parameters,
 Object requestContext)

Method Details

buildDataProducers

protected List<ISingleStageReplicaDataProducer<? extends IExecutableSpaceReplicaData>> buildDataProducers(SpaceCopyReplicaParameters parameters)

Specified by:

buildDataProducers in class AbstractMultiSpaceReplicaDataProducer

toFilterEntry

public IReplicationFilterEntry toFilterEntry(IExecutableSpaceReplicaData data)

getName

public String getName()