com.hazelcast.enterprise.wan.replication

Class WanPublisherMerkleTreeSyncSupport

java.lang.Object

com.hazelcast.enterprise.wan.replication.WanPublisherMerkleTreeSyncSupport

All Implemented Interfaces:

WanPublisherSyncSupport

public class WanPublisherMerkleTreeSyncSupport
extends Object
implements WanPublisherSyncSupport

Support class for processing WAN merkle tree anti-entropy events for a single publisher.

Method Summary

Modifier and Type	Method and Description
void	destroyMapData(String mapName) Releases all resources for the map with the given mapName.
Map<String,com.hazelcast.wan.merkletree.ConsistencyCheckResult>	getLastConsistencyCheckResults() Returns the results of the last WAN consistency checks, grouped by map name.
Map<String,com.hazelcast.wan.WanSyncStats>	getLastSyncStats() Returns the statistics about the last synchronization
void	processEvent(WanConsistencyCheckEvent event, WanAntiEntropyEventResult result) Processes the WAN merkle tree root check event and updates the result with the processing results.
void	processEvent(WanSyncEvent event, WanAntiEntropyEventResult result) Processes the WAN merkle tree sync event.
void	removeReplicationEvent(EnterpriseMapReplicationObject sync) Decrements the counter for pending WAN sync events.

Methods inherited from class java.lang.Object

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

Method Detail

processEvent

public void processEvent(WanConsistencyCheckEvent event,
                         WanAntiEntropyEventResult result)
                  throws Exception

Processes the WAN merkle tree root check event and updates the result with the processing results.

Specified by:

processEvent in interface WanPublisherSyncSupport

Parameters:

event - WAN merkle tree root check event

result - the processing result

Throws:

Exception - if there was an exception when waiting for the results of the merkle tree roots

removeReplicationEvent

public void removeReplicationEvent(EnterpriseMapReplicationObject sync)

Description copied from interface: WanPublisherSyncSupport

Decrements the counter for pending WAN sync events.

Specified by:

removeReplicationEvent in interface WanPublisherSyncSupport

Parameters:

sync - WAN sync event

processEvent

public void processEvent(WanSyncEvent event,
                         WanAntiEntropyEventResult result)
                  throws Exception

Processes the WAN merkle tree sync event.

Specified by:

processEvent in interface WanPublisherSyncSupport

Parameters:

event - WAN merkle tree sync event

result - the result of the processing

Throws:

Exception - if there was an exception when waiting for the results of the merkle tree roots

getLastConsistencyCheckResults

public Map<String,com.hazelcast.wan.merkletree.ConsistencyCheckResult> getLastConsistencyCheckResults()

Description copied from interface: WanPublisherSyncSupport

Returns the results of the last WAN consistency checks, grouped by map name.

Specified by:

getLastConsistencyCheckResults in interface WanPublisherSyncSupport

getLastSyncStats

public Map<String,com.hazelcast.wan.WanSyncStats> getLastSyncStats()

Description copied from interface: WanPublisherSyncSupport

Returns the statistics about the last synchronization

Specified by:

getLastSyncStats in interface WanPublisherSyncSupport

destroyMapData

public void destroyMapData(String mapName)

Description copied from interface: WanPublisherSyncSupport

Releases all resources for the map with the given mapName.

Specified by:

destroyMapData in interface WanPublisherSyncSupport

Parameters:

mapName - the map name