com.hazelcast.enterprise.wan

Class PartitionWanEventContainer

java.lang.Object

com.hazelcast.enterprise.wan.PartitionWanEventContainer

public class PartitionWanEventContainer
extends Object

Contains all map/cache event queues of a partition.

Constructor Summary

Constructors

Constructor and Description
PartitionWanEventContainer()

Method Summary

Modifier and Type	Method and Description
void	clear()
void	drainRandomWanQueue(Collection<com.hazelcast.wan.WanReplicationEvent> drainTo, int elementsToDrain) Removes at most the given number of available elements from a random WAN queue and adds them to the given collection.
PartitionWanEventQueueMap	getCacheEventQueueMapByBackupCount(int backupCount)
PartitionWanEventQueueMap	getMapEventQueueMapByBackupCount(int backupCount)
com.hazelcast.wan.WanReplicationEvent	pollCacheWanEvent(String cacheName) Return the head of the wan event queue for the cacheName
com.hazelcast.wan.WanReplicationEvent	pollMapWanEvent(String mapName) Return the head of the wan event queue for the mapName
boolean	publishCacheWanEvent(String cacheName, com.hazelcast.wan.WanReplicationEvent wanReplicationEvent) Publishes the replicationEvent for the given cacheName cache on the partition partitionId
boolean	publishMapWanEvent(String mapName, com.hazelcast.wan.WanReplicationEvent wanReplicationEvent) Publishes the replicationEvent for the given mapName map on the partition partitionId
int	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionWanEventContainer

public PartitionWanEventContainer()

Method Detail

publishMapWanEvent

public boolean publishMapWanEvent(String mapName,
                                  com.hazelcast.wan.WanReplicationEvent wanReplicationEvent)

Publishes the replicationEvent for the given mapName map on the partition partitionId

Parameters:

mapName - the name of the map for which the event is published

wanReplicationEvent - the published replication event

Returns:

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

pollMapWanEvent

public com.hazelcast.wan.WanReplicationEvent pollMapWanEvent(String mapName)

Return the head of the wan event queue for the mapName

Parameters:

mapName - the map for which an event is polled

Returns:

the replication event

pollCacheWanEvent

public com.hazelcast.wan.WanReplicationEvent pollCacheWanEvent(String cacheName)

Return the head of the wan event queue for the cacheName

Parameters:

cacheName - the cache for which an event is polled

Returns:

the replication event

drainRandomWanQueue

public void drainRandomWanQueue(Collection<com.hazelcast.wan.WanReplicationEvent> drainTo,
                                int elementsToDrain)

Removes at most the given number of available elements from a random WAN queue and adds them to the given collection.

Parameters:

drainTo - the collection to which to drain events to

elementsToDrain - the maximum number of events to drain

size

public int size()

getMapEventQueueMapByBackupCount

public PartitionWanEventQueueMap getMapEventQueueMapByBackupCount(int backupCount)

getCacheEventQueueMapByBackupCount

public PartitionWanEventQueueMap getCacheEventQueueMapByBackupCount(int backupCount)

publishCacheWanEvent

public boolean publishCacheWanEvent(String cacheName,
                                    com.hazelcast.wan.WanReplicationEvent wanReplicationEvent)

Publishes the replicationEvent for the given cacheName cache on the partition partitionId

Parameters:

cacheName - the name of the cache for which the event is published

wanReplicationEvent - the published replication event

Returns:

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

clear

public void clear()