com.hazelcast.enterprise.wan.replication

Class PollSynchronizerPublisherQueueContainer

java.lang.Object

com.hazelcast.enterprise.wan.PublisherQueueContainer

com.hazelcast.enterprise.wan.replication.PollSynchronizerPublisherQueueContainer

public class PollSynchronizerPublisherQueueContainer
extends PublisherQueueContainer

This class is an extension to PublisherQueueContainer that offers synchronization between polling the WAN event queues and other processes such as migration via per-partition locks.

For the time a polling a partition's WAN events is blocked, the drainRandomWanQueue(int, Collection, int) will not drain any events.

Method Summary

Modifier and Type	Method and Description
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.

Methods inherited from class com.hazelcast.enterprise.wan.PublisherQueueContainer

clear, drainCacheQueues, drainMapQueues, drainQueues, drainQueues, getContainers, getEventQueue, pollCacheWanEvent, pollMapWanEvent, publishCacheWanEvent, publishMapWanEvent, size

Methods inherited from class java.lang.Object

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

Method Detail

drainRandomWanQueue

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

Description copied from class: PublisherQueueContainer

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.

Overrides:

drainRandomWanQueue in class PublisherQueueContainer

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