com.hazelcast.enterprise.wan

Class PartitionWanEventQueueMap

java.lang.Object

java.util.AbstractMap<K,V>

java.util.concurrent.ConcurrentHashMap<String,WanReplicationEventQueue>

com.hazelcast.enterprise.wan.PartitionWanEventQueueMap

All Implemented Interfaces:

com.hazelcast.nio.serialization.DataSerializable, Serializable, ConcurrentMap<String,WanReplicationEventQueue>, Map<String,WanReplicationEventQueue>

public class PartitionWanEventQueueMap
extends ConcurrentHashMap<String,WanReplicationEventQueue>
implements com.hazelcast.nio.serialization.DataSerializable

WAN event queue map of a partition and a specific service (map/cache). Contains all map/cache event queues of a partition.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.ConcurrentHashMap

ConcurrentHashMap.KeySetView<K,V>

Nested classes/interfaces inherited from class java.util.AbstractMap

AbstractMap.SimpleEntry<K,V>, AbstractMap.SimpleImmutableEntry<K,V>

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K,V>

Constructor Summary

Constructors

Constructor and Description
PartitionWanEventQueueMap()

Method Summary

Modifier and Type	Method and Description
boolean	offerEvent(com.hazelcast.wan.WanReplicationEvent wanReplicationEvent, String distributedObjectName, int backupCount) Publishes the replicationEvent
com.hazelcast.wan.WanReplicationEvent	pollEvent(String distributedObjectName) Returns a WAN event for the given distributed object or null if there is none.
void	readData(com.hazelcast.nio.ObjectDataInput in)
void	writeData(com.hazelcast.nio.ObjectDataOutput out)

Methods inherited from class java.util.concurrent.ConcurrentHashMap

clear, compute, computeIfAbsent, computeIfPresent, contains, containsKey, containsValue, elements, entrySet, equals, forEach, forEach, forEach, forEachEntry, forEachEntry, forEachKey, forEachKey, forEachValue, forEachValue, get, getOrDefault, hashCode, isEmpty, keys, keySet, keySet, mappingCount, merge, newKeySet, newKeySet, put, putAll, putIfAbsent, reduce, reduceEntries, reduceEntries, reduceEntriesToDouble, reduceEntriesToInt, reduceEntriesToLong, reduceKeys, reduceKeys, reduceKeysToDouble, reduceKeysToInt, reduceKeysToLong, reduceToDouble, reduceToInt, reduceToLong, reduceValues, reduceValues, reduceValuesToDouble, reduceValuesToInt, reduceValuesToLong, remove, remove, replace, replace, replaceAll, search, searchEntries, searchKeys, searchValues, size, toString, values

Methods inherited from class java.util.AbstractMap

clone

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

PartitionWanEventQueueMap

public PartitionWanEventQueueMap()

Method Detail

offerEvent

public boolean offerEvent(com.hazelcast.wan.WanReplicationEvent wanReplicationEvent,
                          String distributedObjectName,
                          int backupCount)

Publishes the replicationEvent

Parameters:

distributedObjectName - the name of the distributed object for which this event is published

backupCount - the number of backup replicas on which this WAN event is stored

wanReplicationEvent - the published replication event

Returns:

true if the element was added to this queue, else false

pollEvent

public com.hazelcast.wan.WanReplicationEvent pollEvent(String distributedObjectName)

Returns a WAN event for the given distributed object or null if there is none.

Parameters:

distributedObjectName - the name of the distributed object

Returns:

the WAN event

writeData

public void writeData(com.hazelcast.nio.ObjectDataOutput out)
               throws IOException

Specified by:

writeData in interface com.hazelcast.nio.serialization.DataSerializable

Throws:

IOException

readData

public void readData(com.hazelcast.nio.ObjectDataInput in)
              throws IOException

Specified by:

readData in interface com.hazelcast.nio.serialization.DataSerializable

Throws:

IOException