public class SpaceCopyReplicaDataProducer extends AbstractMultiSpaceReplicaDataProducer
ISingleStageReplicaDataProducer.CloseStatus
_engine, _logger, _requestContext
FORCED_CLOSE_WAIT_TIME
Constructor and Description |
---|
SpaceCopyReplicaDataProducer(SpaceEngine engine,
SpaceCopyReplicaParameters parameters,
Object requestContext) |
Modifier and Type | Method and Description |
---|---|
protected List<ISingleStageReplicaDataProducer<? extends IExecutableSpaceReplicaData>> |
buildDataProducers(SpaceCopyReplicaParameters parameters) |
String |
getName() |
IReplicationFilterEntry |
toFilterEntry(IExecutableSpaceReplicaData data) |
close, dumpState, getLogPrefix, nextReplicaStage, onClose, produceNextData
public SpaceCopyReplicaDataProducer(SpaceEngine engine, SpaceCopyReplicaParameters parameters, Object requestContext)
protected List<ISingleStageReplicaDataProducer<? extends IExecutableSpaceReplicaData>> buildDataProducers(SpaceCopyReplicaParameters parameters)
buildDataProducers
in class AbstractMultiSpaceReplicaDataProducer
public IReplicationFilterEntry toFilterEntry(IExecutableSpaceReplicaData data)
public String getName()
Copyright © GigaSpaces.