Package com.gigaspaces.internal.cluster.node.impl.gateway.sink

Class LocalClusterReplicationInEntryHandler

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.gateway.sink.AbstractLocalClusterReplicationInHandler

com.gigaspaces.internal.cluster.node.impl.gateway.sink.LocalClusterReplicationInEntryHandler

All Implemented Interfaces:

IReplicationInEntryHandler

public class LocalClusterReplicationInEntryHandler
extends AbstractLocalClusterReplicationInHandler
implements IReplicationInEntryHandler

A handler for a write operation replicated to a gateway sink component.

Since:

8.0.3

Author:

idan

Field Summary

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.gateway.sink.AbstractLocalClusterReplicationInHandler

_config, _spaceProxy

Constructor Summary

Constructors

Constructor	Description
LocalClusterReplicationInEntryHandler(ISpaceProxy spaceProxy, ITransactionManagerProvider transactionManagerProvider, LocalClusterReplicationSinkConfig config)

Method Summary

Modifier and Type	Method	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.cluster.node.impl.gateway.sink.AbstractLocalClusterReplicationInHandler

execute, executeIfUidPresent, executeTransactional, extractSourceGatewayName, getSpaceProxy, handleChangeEntry, handleRemoveEntry, handleRemoveEntryByUid, handleUpdateEntry, handleWriteEntry, invokeConflictResolver

Methods inherited from class java.lang.Object

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

Constructor Details

LocalClusterReplicationInEntryHandler

public LocalClusterReplicationInEntryHandler(ISpaceProxy spaceProxy,
 ITransactionManagerProvider transactionManagerProvider,
 LocalClusterReplicationSinkConfig config)

Method Details

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

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

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