com.gigaspaces.internal.sync.mirror

Class MirrorReplicationInEntryHandler

java.lang.Object

com.gigaspaces.internal.sync.mirror.MirrorReplicationInHandler

com.gigaspaces.internal.sync.mirror.MirrorReplicationInEntryHandler

All Implemented Interfaces:

IReplicationInEntryHandler, ITransactionalBatchExecutionCallback

public class MirrorReplicationInEntryHandler
extends MirrorReplicationInHandler
implements IReplicationInEntryHandler

Handles replicated entry operations on mirror

Since:

8.0

Field Summary

Fields inherited from class com.gigaspaces.internal.sync.mirror.MirrorReplicationInHandler

_syncEndpoint

Constructor Summary

Constructors

Constructor and Description
MirrorReplicationInEntryHandler(MirrorBulkExecutor bulkExecutor, MirrorStatisticsImpl operationStatisticsHandler)

Method Summary

Modifier and Type	Method and Description
void	afterConsumption(IReplicationInContext context, boolean successful, long lastProcessedKey)
void	beforeConsume(IReplicationInContext context)
void	inChangeEntry(IReplicationInContext context, String typeName, String uid, Object id, int version, int previousVersion, int routingHash, long timeToLive, Collection<SpaceEntryMutator> mutators, boolean isTransient, OperationID operationID)
void	inRemoveEntry(IReplicationInContext context, IEntryPacket entryPacket)
void	inRemoveEntryByUID(IReplicationInContext context, String typeName, String uid, boolean isTransient, OperationID operationID)
void	inUpdateEntry(IReplicationInContext context, IEntryPacket entryPacket, IEntryPacket oldEntryPacket, boolean partialUpdate, boolean overrideVersion, short flags)
void	inWriteEntry(IReplicationInContext context, IEntryPacket entryPacket)

Methods inherited from class com.gigaspaces.internal.sync.mirror.MirrorReplicationInHandler

addChangeEntry, addRemoveEntry, addTransaction, addUpdateEntry, addWriteEntry, changeEntry, execute, getTypeManager, removeEntry, removeEntryByUID, updateEntry, writeEntry

Methods inherited from class java.lang.Object

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

Constructor Detail

MirrorReplicationInEntryHandler

public MirrorReplicationInEntryHandler(MirrorBulkExecutor bulkExecutor,
                                       MirrorStatisticsImpl operationStatisticsHandler)

Method Detail

inWriteEntry

public void inWriteEntry(IReplicationInContext context,
                         IEntryPacket entryPacket)
                  throws Exception

Specified by:

inWriteEntry in interface IReplicationInEntryHandler

Throws:

Exception

inUpdateEntry

public void inUpdateEntry(IReplicationInContext context,
                          IEntryPacket entryPacket,
                          IEntryPacket oldEntryPacket,
                          boolean partialUpdate,
                          boolean overrideVersion,
                          short flags)
                   throws Exception

Specified by:

inUpdateEntry in interface IReplicationInEntryHandler

Throws:

Exception

inRemoveEntry

public void inRemoveEntry(IReplicationInContext context,
                          IEntryPacket entryPacket)
                   throws Exception

Specified by:

inRemoveEntry in interface IReplicationInEntryHandler

Throws:

Exception

inRemoveEntryByUID

public void inRemoveEntryByUID(IReplicationInContext context,
                               String typeName,
                               String uid,
                               boolean isTransient,
                               OperationID operationID)
                        throws Exception

Specified by:

inRemoveEntryByUID in interface IReplicationInEntryHandler

Throws:

Exception

afterConsumption

public void afterConsumption(IReplicationInContext context,
                             boolean successful,
                             long lastProcessedKey)

Specified by:

afterConsumption in interface IReplicationInEntryHandler

beforeConsume

public void beforeConsume(IReplicationInContext context)

Specified by:

beforeConsume in interface IReplicationInEntryHandler

inChangeEntry

public void inChangeEntry(IReplicationInContext context,
                          String typeName,
                          String uid,
                          Object id,
                          int version,
                          int previousVersion,
                          int routingHash,
                          long timeToLive,
                          Collection<SpaceEntryMutator> mutators,
                          boolean isTransient,
                          OperationID operationID)
                   throws Exception

Specified by:

inChangeEntry in interface IReplicationInEntryHandler

Throws:

Exception