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

Class DirectPersisntecyEntryReplicaProducer

java.lang.Object

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

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

All Implemented Interfaces:

ISingleStageReplicaDataProducer<AbstractEntryReplicaData>

public class DirectPersisntecyEntryReplicaProducer
extends EntryReplicaProducer

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 and Description
protected static Logger	_logger

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.replica.EntryReplicaProducer

_engine

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

FORCED_CLOSE_WAIT_TIME

Constructor Summary

Constructors

Constructor and Description
DirectPersisntecyEntryReplicaProducer(SpaceEngine engine, SpaceCopyReplicaParameters parameters, ITemplatePacket templatePacket, Object requestContext)

Method Summary

Modifier and Type	Method and Description
String	getName()
AbstractEntryReplicaData	produceNextData(ISynchronizationCallback syncCallback) Creates the next entry that will be copied to the source space

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

close, dumpState, getEngine, getParameters, getRequestContext, increaseGeneratedDataCount, isClosed, isForcedClose, produceDataFromEntry, toFilterEntry

Methods inherited from class java.lang.Object

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

Field Detail

_logger

protected static final Logger _logger

Constructor Detail

DirectPersisntecyEntryReplicaProducer

public DirectPersisntecyEntryReplicaProducer(SpaceEngine engine,
                                             SpaceCopyReplicaParameters parameters,
                                             ITemplatePacket templatePacket,
                                             Object requestContext)

Method Detail

produceNextData

public AbstractEntryReplicaData produceNextData(ISynchronizationCallback syncCallback)

Description copied from class: EntryReplicaProducer

Creates the next entry that will be copied to the source space

Specified by:

produceNextData in interface ISingleStageReplicaDataProducer<AbstractEntryReplicaData>

Overrides:

produceNextData in class EntryReplicaProducer

Parameters:

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

Returns:

the next data to replicate or null if there is not more data

getName

public String getName()

Specified by:

getName in interface ISingleStageReplicaDataProducer<AbstractEntryReplicaData>

Overrides:

getName in class EntryReplicaProducer