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.
int	drainQueues(int partitionId) Drains all the queues maintained for the given partition.
void	drainRandomWanQueue(int partitionId, Collection<com.hazelcast.wan.WanReplicationEvent> drainTo, int elementsToDrain) Removes at most the given number of available elements from a random WAN queue and for the given partition and adds them to the given collection.
PartitionWanEventContainer[]	getContainers() Returns all of the partition WAN event queue containers.
PartitionWanEventContainer	getEventQueue(int partitionId) Returns the PartitionWanEventContainer for the specified partitionId.
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.
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

drainRandomWanQueue

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

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

Parameters:

partitionId - the partition ID for which a random WAN queue should be drained

drainTo - the collection to which to drain events to

elementsToDrain - the maximum number of events to drain

getEventQueue

public PartitionWanEventContainer getEventQueue(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

drainQueues

public int drainQueues(int partitionId)

Drains all the queues maintained for the given partition.

Parameters:

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

Returns:

the number of drained elements

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

getContainers

public PartitionWanEventContainer[] getContainers()

Returns all of the partition WAN event queue containers.

clear

public void clear()

Clears all WAN queues in all containers.