com.gigaspaces.internal.cluster.node.handlers

Class AbstractReplicationEntryEventHandler

java.lang.Object

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

All Implemented Interfaces:

IReplicationInEntryHandler

Direct Known Subclasses:

AbstractSpaceReplicationEntryEventHandler, LocalViewReplicationEntryEventHandler

public abstract class AbstractReplicationEntryEventHandler
extends Object
implements IReplicationInEntryHandler

Since:

8.0.5

Author:

Niv Ingberg

Constructor Summary

Constructors

Constructor and Description
AbstractReplicationEntryEventHandler()

Method Summary

Modifier and Type	Method and Description
void	afterConsumption(IReplicationInContext context, boolean successful, long lastProcessedKey)
void	beforeConsume(IReplicationInContext context)
abstract 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 previousEntryData)
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 entry)
void	inRemoveEntryByUID(IReplicationInContext context, String typeName, String uid, boolean isTransient, OperationID operationID)
void	inUpdateEntry(IReplicationInContext context, IEntryPacket entry, IEntryPacket oldEntryPacket, boolean partialUpdate, boolean overrideVersion, short flags)
void	inWriteEntry(IReplicationInContext context, IEntryPacket entry)
abstract void	removeEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry)
abstract void	removeEntryByUid(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, String uid, boolean isTransient, OperationID operationID)
abstract void	updateEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry, IEntryPacket previousPacket, boolean partialUpdate, boolean overrideVersion)
abstract void	writeEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractReplicationEntryEventHandler

public AbstractReplicationEntryEventHandler()

Method Detail

inWriteEntry

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

Specified by:

inWriteEntry in interface IReplicationInEntryHandler

Throws:

Exception

inUpdateEntry

public void inUpdateEntry(IReplicationInContext context,
                          IEntryPacket entry,
                          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 entry)
                   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

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

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

writeEntry

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

Throws:

Exception

updateEntry

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

Throws:

Exception

removeEntry

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

Throws:

Exception

removeEntryByUid

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

Throws:

Exception

changeEntry

public abstract 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 previousEntryData)
                          throws Exception

Throws:

Exception