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 dataStructure, int backupCount)
com.hazelcast.wan.WanReplicationEvent	pollEvent(String dataStructureName)
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 dataStructure,
                          int backupCount)

pollEvent

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

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