com.gigaspaces.internal.cluster.node.handlers

Interface IReplicationInEntryHandler

All Known Subinterfaces:

IReplicationInFacade

All Known Implementing Classes:

AbstractReplicationEntryEventHandler, AbstractReplicationNotificationInEntryHandler, AbstractSpaceReplicationEntryEventHandler, ActiveActiveSpaceReplicationEntryEventHandler, BlobstorePrimaryBackupSpaceReplicationEntryEventHandler, LocalClusterReplicationInEntryHandler, LocalViewReplicationEntryEventHandler, MirrorReplicationInEntryHandler, PrimaryBackupSpaceReplicationEntryEventHandler, PrimaryBackupSpaceReplicationEvictionProtectionEntryEventHandler, ReplicationNodeInFacade, ReplicationNotificationBatchInEntryHandler, ReplicationNotificationInEntryHandler

public interface IReplicationInEntryHandler

Since:

10.0

Author:

Niv Ingberg

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)

Method Detail

inWriteEntry

void inWriteEntry(IReplicationInContext context,
                  IEntryPacket entryPacket)
           throws Exception

Throws:

Exception

inUpdateEntry

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

Throws:

Exception

inChangeEntry

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

Throws:

Exception

inRemoveEntry

void inRemoveEntry(IReplicationInContext context,
                   IEntryPacket entryPacket)
            throws Exception

Throws:

Exception

inRemoveEntryByUID

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

Throws:

Exception

afterConsumption

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

beforeConsume

void beforeConsume(IReplicationInContext context)