com.gigaspaces.internal.client.cache.localview.replication

Class LocalViewReplicationEntryEventHandler

java.lang.Object

com.gigaspaces.internal.cluster.node.handlers.AbstractReplicationEntryEventHandler

com.gigaspaces.internal.client.cache.localview.replication.LocalViewReplicationEntryEventHandler

All Implemented Interfaces:

IReplicationInEntryHandler

public class LocalViewReplicationEntryEventHandler
extends AbstractReplicationEntryEventHandler

Since:

8.0.5

Author:

Niv Ingberg

Constructor Summary

Constructors

Constructor and Description
LocalViewReplicationEntryEventHandler(SpaceEngine engine)

Method Summary

Modifier and Type	Method and Description
void	changeEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, String typeName, String uid, Object id, int routingHash, int version, int previousVersion, long timeToLive, Collection<SpaceEntryMutator> mutators, boolean isTransient, OperationID operationID, IEntryData previousEntry)
void	removeEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry)
void	removeEntryByUid(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, String uid, boolean isTransient, OperationID operationID, String typeName)
void	updateEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry, IEntryPacket previousPacket, boolean partialUpdate, boolean overrideVersion)
void	writeEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry)

Methods inherited from class com.gigaspaces.internal.cluster.node.handlers.AbstractReplicationEntryEventHandler

afterConsumption, beforeConsume, inChangeEntry, inRemoveEntry, inRemoveEntryByUID, inUpdateEntry, inWriteEntry

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalViewReplicationEntryEventHandler

public LocalViewReplicationEntryEventHandler(SpaceEngine engine)

Method Detail

writeEntry

public void writeEntry(IReplicationInContext context,
                       Transaction txn,
                       boolean twoPhaseCommit,
                       IEntryPacket entry)
                throws Exception

Specified by:

writeEntry in class AbstractReplicationEntryEventHandler

Throws:

Exception

updateEntry

public void updateEntry(IReplicationInContext context,
                        Transaction txn,
                        boolean twoPhaseCommit,
                        IEntryPacket entry,
                        IEntryPacket previousPacket,
                        boolean partialUpdate,
                        boolean overrideVersion)
                 throws Exception

Specified by:

updateEntry in class AbstractReplicationEntryEventHandler

Throws:

Exception

removeEntry

public void removeEntry(IReplicationInContext context,
                        Transaction txn,
                        boolean twoPhaseCommit,
                        IEntryPacket entry)
                 throws Exception

Specified by:

removeEntry in class AbstractReplicationEntryEventHandler

Throws:

Exception

removeEntryByUid

public void removeEntryByUid(IReplicationInContext context,
                             Transaction txn,
                             boolean twoPhaseCommit,
                             String uid,
                             boolean isTransient,
                             OperationID operationID,
                             String typeName)
                      throws Exception

Specified by:

removeEntryByUid in class AbstractReplicationEntryEventHandler

Throws:

Exception

changeEntry

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

Specified by:

changeEntry in class AbstractReplicationEntryEventHandler

Throws:

Exception