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

Class SynchronizeReplicaDataProducer

java.lang.Object

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

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

All Implemented Interfaces:

ISingleStageReplicaDataProducer<IExecutableSpaceReplicaData>, ISpaceReplicaDataProducer<IExecutableSpaceReplicaData>

public class SynchronizeReplicaDataProducer
extends AbstractMultiSpaceReplicaDataProducer

SynchronizeReplicaDataProducer copies all the entries in space and all the notifications

Since:

8.0

Version:

1.0

Author:

anna

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 and Description
SynchronizeReplicaDataProducer(SpaceEngine engine, SpaceCopyReplicaParameters parameters, Object requestContext)

Method Summary

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

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

close, dumpState, getLogPrefix, nextReplicaStage, produceNextData

Methods inherited from class java.lang.Object

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

Constructor Detail

SynchronizeReplicaDataProducer

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

Method Detail

buildDataProducers

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

Specified by:

buildDataProducers in class AbstractMultiSpaceReplicaDataProducer

onClose

public void onClose()

Overrides:

onClose in class AbstractMultiSpaceReplicaDataProducer

toFilterEntry

public IReplicationFilterEntry toFilterEntry(IExecutableSpaceReplicaData data)

getName

public String getName()