com.gigaspaces.cluster.replication.gateway.conflict
Class ConflictResolver

java.lang.Object
  com.gigaspaces.cluster.replication.gateway.conflict.ConflictResolver

public abstract class ConflictResolver
extends Object

A base class for a gateway replication Sink component conflict resolver. An appropriate method is invoked for the following conflicts:

1. DataConflict - conflicts caused by write/update/take operation execution.
2. RegisterTypeDescriptorConflict - conflict caused by a type registration operation execution.
3. AddIndexConflict - conflict caused by an add indexes operation execution.

The conflict resolver will be called if there is some conflict when attempting to apply the replication affect into the local space. If the cause for the conflict is EntryLockedUnderTransactionConflict, there will be an automatic retry of the operation according to predefined configuration. In such case the conflict resolver is invoked only after the amount of configurable operation retries has exceeded and the EntryLockedUnderTransactionConflict conflict still occurs.

Since:

8.0.3

Author:

eitany

Constructor Summary

ConflictResolver()

Method Summary

void	onAddIndexConflict(String sourceGatewayName, AddIndexConflict conflict) Invoked after an AddIndexConflict occurred.
void	onDataConflict(String sourceGatewayName, DataConflict conflict) Invoked after a DataConflict occurred.
void	onRegisterTypeDescriptorConflict(String sourceGatewayName, RegisterTypeDescriptorConflict conflict) Invoked after a RegisterTypeDescriptorConflict occurred.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConflictResolver

public ConflictResolver()

Method Detail

onDataConflict

public void onDataConflict(String sourceGatewayName,
                           DataConflict conflict)

Invoked after a DataConflict occurred. The default behavior of the conflict resolver is to abort all the operation that exists inside the provided DataConflict.

Parameters:

sourceGatewayName - The source gateway name the operations were replicated from.

conflict - The DataConflict instance representing the conflict.

onRegisterTypeDescriptorConflict

public void onRegisterTypeDescriptorConflict(String sourceGatewayName,
                                             RegisterTypeDescriptorConflict conflict)

Invoked after a RegisterTypeDescriptorConflict occurred.

Parameters:

sourceGatewayName - The source gateway name the operation was replicated from.

conflict - The RegisterTypeDescriptorConflict instance representing the conflict.

onAddIndexConflict

public void onAddIndexConflict(String sourceGatewayName,
                               AddIndexConflict conflict)

Invoked after an AddIndexConflict occurred.

Parameters:

sourceGatewayName - The source gateway name the operation was replicated from.

conflict - The AddIndexConflict instance representing the conflict.