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

Method Summary

Modifier and Type	Method and 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 Detail

SpaceBroadcastNotifyReplicaDataProducer

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

Method Detail

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