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

Class AbstractLocalClusterReplicationInHandler

java.lang.Object

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

Direct Known Subclasses:

LocalClusterReplicationEntryLeaseEventHandler, LocalClusterReplicationInBatchConsumptionHandler, LocalClusterReplicationInEntryHandler, LocalClusterReplicationInTransactionHandler, LocalClusterReplicationMetadataEventHandler

public abstract class AbstractLocalClusterReplicationInHandler
extends Object

A base class for local cluster replication in handlers used by a gateway Sink component.

Since:

8.0.3

Author:

idan

Field Summary

Fields

Modifier and Type	Field and Description
protected LocalClusterReplicationSinkConfig	_config
protected ISpaceProxy	_spaceProxy

Constructor Summary

Constructors

Constructor and Description
AbstractLocalClusterReplicationInHandler(ISpaceProxy spaceProxy, ITransactionManagerProvider transactionManagerProvider, LocalClusterReplicationSinkConfig config)

Method Summary

Modifier and Type	Method and Description
protected void	execute(IReplicationInBatchContext batchContext)
protected void	executeIfUidPresent(IReplicationInBatchContext batchContext, String uid)
protected void	executeTransactional(IReplicationInBatchContext batchContext, ITransactionInContext transactionContext)
protected String	extractSourceGatewayName(IReplicationInBatchContext batchContext)
ISpaceProxy	getSpaceProxy()
protected void	handleChangeEntry(String typeName, String uid, Object id, int version, int previousVersion, int routingHash, long timeToLive, Collection<SpaceEntryMutator> mutators, IReplicationInBatchContext batchContext)
protected void	handleRemoveEntry(IEntryPacket entryPacket, IReplicationInBatchContext batchContext)
protected void	handleRemoveEntryByUid(String typeName, String uid, IReplicationInBatchContext batchContext)
protected void	handleUpdateEntry(IEntryPacket entryPacket, IEntryPacket oldEntryPacket, IReplicationInBatchContext batchContext, boolean partialUpdate)
protected void	handleWriteEntry(IEntryPacket entryPacket, IReplicationInBatchContext batchContext)
protected void	invokeConflictResolver(IReplicationInBatchContext batchContext, LocalClusterReplicationDataConflict conflictData, boolean fromTransaction)

Methods inherited from class java.lang.Object

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

Field Detail

_spaceProxy

protected final ISpaceProxy _spaceProxy

_config

protected final LocalClusterReplicationSinkConfig _config

Constructor Detail

AbstractLocalClusterReplicationInHandler

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

Method Detail

execute

protected void execute(IReplicationInBatchContext batchContext)
                throws Exception

Throws:

Exception

executeTransactional

protected void executeTransactional(IReplicationInBatchContext batchContext,
                                    ITransactionInContext transactionContext)
                             throws Exception

Throws:

Exception

getSpaceProxy

public ISpaceProxy getSpaceProxy()

Returns:

ISpaceProxy instance operations are executed against.

handleWriteEntry

protected void handleWriteEntry(IEntryPacket entryPacket,
                                IReplicationInBatchContext batchContext)
                         throws UnknownTypeException

Throws:

UnknownTypeException

handleUpdateEntry

protected void handleUpdateEntry(IEntryPacket entryPacket,
                                 IEntryPacket oldEntryPacket,
                                 IReplicationInBatchContext batchContext,
                                 boolean partialUpdate)
                          throws UnknownTypeException

Throws:

UnknownTypeException

handleRemoveEntry

protected void handleRemoveEntry(IEntryPacket entryPacket,
                                 IReplicationInBatchContext batchContext)
                          throws UnknownTypeException

Throws:

UnknownTypeException

handleChangeEntry

protected void handleChangeEntry(String typeName,
                                 String uid,
                                 Object id,
                                 int version,
                                 int previousVersion,
                                 int routingHash,
                                 long timeToLive,
                                 Collection<SpaceEntryMutator> mutators,
                                 IReplicationInBatchContext batchContext)
                          throws UnknownTypeException

Throws:

UnknownTypeException

handleRemoveEntryByUid

protected void handleRemoveEntryByUid(String typeName,
                                      String uid,
                                      IReplicationInBatchContext batchContext)
                               throws UnknownTypeException

Throws:

UnknownTypeException

invokeConflictResolver

protected void invokeConflictResolver(IReplicationInBatchContext batchContext,
                                      LocalClusterReplicationDataConflict conflictData,
                                      boolean fromTransaction)

extractSourceGatewayName

protected String extractSourceGatewayName(IReplicationInBatchContext batchContext)

executeIfUidPresent

protected void executeIfUidPresent(IReplicationInBatchContext batchContext,
                                   String uid)
                            throws Exception

Throws:

Exception