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()
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
com.hazelcast.wan.WanReplicationEvent	pollRandomWanEvent() Returns an event from a random map or cache queue or null if there are no events.
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

pollRandomWanEvent

public com.hazelcast.wan.WanReplicationEvent pollRandomWanEvent()

Returns an event from a random map or cache queue or null if there are no events.

Returns:

a WAN event or null if there are none

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()