com.hazelcast.enterprise.wan.sync

Class WanAntiEntropyEvent

java.lang.Object

com.hazelcast.enterprise.wan.sync.WanAntiEntropyEvent

All Implemented Interfaces:

com.hazelcast.nio.serialization.DataSerializable, com.hazelcast.nio.serialization.IdentifiedDataSerializable

Direct Known Subclasses:

WanConsistencyCheckEvent, WanSyncEvent

public abstract class WanAntiEntropyEvent
extends Object
implements com.hazelcast.nio.serialization.IdentifiedDataSerializable

Base class for WAN anti-entropy related events.

Field Summary

Fields

Modifier and Type	Field and Description
protected String	mapName The name of the map, can be null in case of WanSyncType.ALL_MAPS
protected Set<Integer>	partitionSet The partitions to be synced.

Constructor Summary

Constructors

Constructor and Description
WanAntiEntropyEvent()
WanAntiEntropyEvent(String mapName)

Method Summary

Modifier and Type	Method and Description
abstract WanAntiEntropyEvent	cloneWithoutPartitionKeys() Clones this object with all data except the partition keys the event applies to.
int	getFactoryId()
String	getMapName()
WanAntiEntropyEventPublishOperation	getOp()
Set<Integer>	getPartitionSet()
WanAntiEntropyEventResult	getProcessingResult()
void	sendResponse() Sends the response with the processing result to the event sender.
void	setOp(WanAntiEntropyEventPublishOperation op)
void	setPartitionSet(Set<Integer> partitionSet)
void	setProcessingResult(WanAntiEntropyEventResult processingResult)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.nio.serialization.IdentifiedDataSerializable

getId

Methods inherited from interface com.hazelcast.nio.serialization.DataSerializable

readData, writeData

Field Detail

mapName

protected String mapName

The name of the map, can be null in case of WanSyncType.ALL_MAPS

partitionSet

protected Set<Integer> partitionSet

The partitions to be synced. If empty, all partitions will be synced

Constructor Detail

WanAntiEntropyEvent

public WanAntiEntropyEvent()

WanAntiEntropyEvent

public WanAntiEntropyEvent(String mapName)

Method Detail

getMapName

public String getMapName()

getPartitionSet

public Set<Integer> getPartitionSet()

setPartitionSet

public void setPartitionSet(Set<Integer> partitionSet)

getOp

public WanAntiEntropyEventPublishOperation getOp()

setOp

public void setOp(WanAntiEntropyEventPublishOperation op)

getProcessingResult

public WanAntiEntropyEventResult getProcessingResult()

setProcessingResult

public void setProcessingResult(WanAntiEntropyEventResult processingResult)

sendResponse

public void sendResponse()

Sends the response with the processing result to the event sender.

getFactoryId

public int getFactoryId()

Specified by:

getFactoryId in interface com.hazelcast.nio.serialization.IdentifiedDataSerializable

cloneWithoutPartitionKeys

public abstract WanAntiEntropyEvent cloneWithoutPartitionKeys()

Clones this object with all data except the partition keys the event applies to.

Returns:

a cloned instance