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

Class SpaceBroadcastNotifyReplicaDataProducer

java.lang.Object

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

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

All Implemented Interfaces:

ISingleStageReplicaDataProducer<IExecutableSpaceReplicaData>, ISpaceReplicaDataProducer<IExecutableSpaceReplicaData>

public class SpaceBroadcastNotifyReplicaDataProducer
extends AbstractMultiSpaceReplicaDataProducer

BroadcastNotifyTemplateReplicaProducer creates a replica of the space broadcast notifications. Used to recover broadcast notify template from other partitions.

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	Description
SpaceBroadcastNotifyReplicaDataProducer(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

SpaceBroadcastNotifyReplicaDataProducer

public SpaceBroadcastNotifyReplicaDataProducer(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()