wanActiveActive

Class WANConflictResolver

java.lang.Object

wanActiveActive.WANConflictResolver

All Implemented Interfaces:

com.gemstone.gemfire.cache.Declarable, com.gemstone.gemfire.cache.util.GatewayConflictResolver, Dialog.CloseCallback

public class WANConflictResolver
extends Object
implements com.gemstone.gemfire.cache.util.GatewayConflictResolver, com.gemstone.gemfire.cache.Declarable, Dialog.CloseCallback

Class WANConflictResolver is a GatewayConflictResolver provides several alternative methods for resolving conflicts in a WAN configuration when multiple sites are modifying the same objects.

The resolver is installed into the cache through eu-hub/cache.xml and us-hub/cache.xml. These determine the type of conflict resolution that will be performed. The options are:

      use-latest
      merge
      highest-int
 

use-latest will select to keep the event with the latest timestamp.
merge will select to merge the values together.
highest-int will select to keep the event with the highest modificationCount field.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	numberOfConflicts Counter tracking the number of conflicting events received

Constructor Summary

Constructors

Constructor and Description
WANConflictResolver()

Method Summary

Methods

Modifier and Type	Method and Description
void	close() This is invoked when the dialog closes.
void	init(Properties p) Initializes this WANConflictResolver.
void	onEvent(com.gemstone.gemfire.cache.util.TimestampedEntryEvent event, com.gemstone.gemfire.cache.util.GatewayConflictHelper helper)

Methods inherited from class java.lang.Object

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

Field Detail

numberOfConflicts

protected int numberOfConflicts

Counter tracking the number of conflicting events received

Constructor Detail

WANConflictResolver

public WANConflictResolver()

Method Detail

init

public void init(Properties p)

Initializes this WANConflictResolver.

Specified by:

init in interface com.gemstone.gemfire.cache.Declarable

Parameters:

p - The Properties with which to initialize this WANConflictResolver

onEvent

public void onEvent(com.gemstone.gemfire.cache.util.TimestampedEntryEvent event,
           com.gemstone.gemfire.cache.util.GatewayConflictHelper helper)

Specified by:

onEvent in interface com.gemstone.gemfire.cache.util.GatewayConflictResolver

close

public void close()

This is invoked when the dialog closes. It will cause the server to shut down.

Specified by:

close in interface Dialog.CloseCallback