com.hazelcast.enterprise.wan

Class PublisherQueueContainer

java.lang.Object

com.hazelcast.enterprise.wan.PublisherQueueContainer

Direct Known Subclasses:

PollSynchronizerPublisherQueueContainer

public class PublisherQueueContainer
extends Object

WAN event queue container for WAN replication publishers. Each WAN queue container is responsible for a specific partition. Provides methods to push/pull WAN events to/from queues.

Constructor Summary

Constructors

Constructor and Description
PublisherQueueContainer(com.hazelcast.instance.Node node)

Method Summary

Modifier and Type	Method and Description
void	clear() Clears all WAN queues in all containers.
int	drainCacheQueues(int partitionId) Drains all the cache queues maintained for the given partition.
int	drainMapQueues(int partitionId) Drains all the map queues maintained for the given partition.
Map<Integer,Integer>	drainQueues() Drains all the queues stored in this container and returns the total of the drained elements in a map, per partition.
PartitionWanEventContainer	getPublisherEventQueue(int partitionId) Returns the PartitionWanEventContainer for the specified partitionId.
Map<Integer,PartitionWanEventContainer>	getPublisherEventQueueMap() Returns the map of partition ID to PartitionWanEventContainer for the specific partition
com.hazelcast.wan.WanReplicationEvent	pollCacheWanEvent(String nameWithPrefix, int partitionId) Polls the wan event queue for the cache with the name nameWithPrefix on partition partitionId.
com.hazelcast.wan.WanReplicationEvent	pollMapWanEvent(String mapName, int partitionId) Polls the wan event queue for the map with the name mapName on partition partitionId.
com.hazelcast.wan.WanReplicationEvent	pollRandomWanEvent(int partitionId) Returns a random replication event for the partitionId.
boolean	publishCacheWanEvent(String nameWithPrefix, int partitionId, com.hazelcast.wan.WanReplicationEvent replicationEvent) Publishes the replicationEvent for the cache with the name nameWithPrefix on the partition partitionId.
boolean	publishMapWanEvent(String mapName, int partitionId, com.hazelcast.wan.WanReplicationEvent replicationEvent) Publishes the replicationEvent for the given mapName map on the partition partitionId
int	size(int partitionId) Returns the size of all WAN queues for the given partitionId.

Methods inherited from class java.lang.Object

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

Constructor Detail

PublisherQueueContainer

public PublisherQueueContainer(com.hazelcast.instance.Node node)

Method Detail

pollCacheWanEvent

public com.hazelcast.wan.WanReplicationEvent pollCacheWanEvent(String nameWithPrefix,
                                                               int partitionId)

Polls the wan event queue for the cache with the name nameWithPrefix on partition partitionId.

Parameters:

nameWithPrefix - the cache name

partitionId - the partition of the wan event

Returns:

the wan replication event

publishCacheWanEvent

public boolean publishCacheWanEvent(String nameWithPrefix,
                                    int partitionId,
                                    com.hazelcast.wan.WanReplicationEvent replicationEvent)

Publishes the replicationEvent for the cache with the name nameWithPrefix on the partition partitionId.

Parameters:

nameWithPrefix - the cache name

partitionId - the partition ID for the published event

replicationEvent - 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,
                                                             int partitionId)

Polls the wan event queue for the map with the name mapName on partition partitionId.

Parameters:

mapName - the map name

partitionId - the partition of the wan event

Returns:

the wan replication event

publishMapWanEvent

public boolean publishMapWanEvent(String mapName,
                                  int partitionId,
                                  com.hazelcast.wan.WanReplicationEvent replicationEvent)

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

partitionId - the partition ID for the published event

replicationEvent - the published replication event

Returns:

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

pollRandomWanEvent

public com.hazelcast.wan.WanReplicationEvent pollRandomWanEvent(int partitionId)

Returns a random replication event for the partitionId.

Parameters:

partitionId - the partition ID for the replication event

Returns:

a random replication event for the given partition ID

getPublisherEventQueueMap

public Map<Integer,PartitionWanEventContainer> getPublisherEventQueueMap()

Returns the map of partition ID to PartitionWanEventContainer for the specific partition

getPublisherEventQueue

public PartitionWanEventContainer getPublisherEventQueue(int partitionId)

Returns the PartitionWanEventContainer for the specified partitionId.

Parameters:

partitionId - the partition ID for the WAN event container

Returns:

the WAN event container

size

public int size(int partitionId)

Returns the size of all WAN queues for the given partitionId.

Parameters:

partitionId - the partition ID

Returns:

the size of the WAN queue

drainQueues

public Map<Integer,Integer> drainQueues()

Drains all the queues stored in this container and returns the total of the drained elements in a map, per partition.

Returns:

the number of drained elements per partition

drainMapQueues

public int drainMapQueues(int partitionId)

Drains all the map queues maintained for the given partition.

Parameters:

partitionId - the partition ID for which queues need to be drained

Returns:

the number of drained elements

drainCacheQueues

public int drainCacheQueues(int partitionId)

Drains all the cache queues maintained for the given partition.

Parameters:

partitionId - the partition ID for which queues need to be drained

Returns:

the number of drained elements

clear

public void clear()

Clears all WAN queues in all containers.