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

Class NotifyTemplateReplicaProducer

java.lang.Object

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

All Implemented Interfaces:

ISingleStageReplicaDataProducer<NotifyTemplateReplicaData>

Direct Known Subclasses:

BroadcastNotifyTemplateReplicaProducer

public class NotifyTemplateReplicaProducer
extends Object
implements ISingleStageReplicaDataProducer<NotifyTemplateReplicaData>

Nested Class Summary

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

ISingleStageReplicaDataProducer.CloseStatus

Field Summary

Fields

Modifier and Type	Field	Description
protected static final org.slf4j.Logger	_logger
protected final Object	_requestContext

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

FORCED_CLOSE_WAIT_TIME

Constructor Summary

Constructors

Constructor	Description
NotifyTemplateReplicaProducer(SpaceEngine engine, Object requestContext)

Method Summary

Modifier and Type	Method	Description
protected ITemplatePacket	buildNotifyTemplatePacket(NotifyTemplateHolder templateHolder, long ttl)
ISingleStageReplicaDataProducer.CloseStatus	close(boolean forced)	Closes the producer, frees up resources held in order to service the replica request.
String	dumpState()
protected String	getDumpName()
protected String	getLogPrefix()
String	getName()
protected boolean	isRelevant(NotifyTemplateHolder notifyTemplate)
NotifyTemplateReplicaData	produceNextData(ISynchronizationCallback syncCallback)	Produce next data needed for replica, this call will always be followed by #releaseLockedData(ISpaceReplicaData) if lockedData is true, it should keep that item represented by this data locked until the release is called This is done in order to ensure synchronization correctness
IReplicationFilterEntry	toFilterEntry(NotifyTemplateReplicaData data)

Methods inherited from class java.lang.Object

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

Field Details

_logger

protected static final org.slf4j.Logger _logger

_requestContext

protected final Object _requestContext

Constructor Details

NotifyTemplateReplicaProducer

public NotifyTemplateReplicaProducer(SpaceEngine engine,
 Object requestContext)

Method Details

produceNextData

public NotifyTemplateReplicaData produceNextData(ISynchronizationCallback syncCallback)

Description copied from interface: ISingleStageReplicaDataProducer

Produce next data needed for replica, this call will always be followed by #releaseLockedData(ISpaceReplicaData) if lockedData is true, it should keep that item represented by this data locked until the release is called This is done in order to ensure synchronization correctness

Specified by:

produceNextData in interface ISingleStageReplicaDataProducer<NotifyTemplateReplicaData>

Parameters:

syncCallback - callback to the synchronization processor that needs to be called safely under lock

Returns:

next data needed for replica, null if done. Once null is returns all executive calls must return null!

close

public ISingleStageReplicaDataProducer.CloseStatus close(boolean forced)

Description copied from interface: ISingleStageReplicaDataProducer

Closes the producer, frees up resources held in order to service the replica request.

Specified by:

close in interface ISingleStageReplicaDataProducer<NotifyTemplateReplicaData>

Returns:

CloseStatus - the status of the close operation, can be CLOSED and CLOSING (another thread is closing already)

isRelevant

protected boolean isRelevant(NotifyTemplateHolder notifyTemplate)

buildNotifyTemplatePacket

protected ITemplatePacket buildNotifyTemplatePacket(NotifyTemplateHolder templateHolder,
 long ttl)

Parameters:

ttl -

toFilterEntry

public IReplicationFilterEntry toFilterEntry(NotifyTemplateReplicaData data)

Specified by:

toFilterEntry in interface ISingleStageReplicaDataProducer<NotifyTemplateReplicaData>

getLogPrefix

protected String getLogPrefix()

dumpState

public String dumpState()

Specified by:

dumpState in interface ISingleStageReplicaDataProducer<NotifyTemplateReplicaData>

getDumpName

protected String getDumpName()

getName

public String getName()

Specified by:

getName in interface ISingleStageReplicaDataProducer<NotifyTemplateReplicaData>