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 pollRandomWanEvent(int) returns null instead of blocking the poller thread to enable that the poller thread may continue with other not blocked partitions.

Method Summary

Modifier and Type	Method and Description
com.hazelcast.wan.WanReplicationEvent	pollRandomWanEvent(int partitionId) Returns a random replication event for the partitionId.

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

clear, drainCacheQueues, drainMapQueues, drainQueues, getPublisherEventQueue, getPublisherEventQueueMap, 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

pollRandomWanEvent

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

Description copied from class: PublisherQueueContainer

Returns a random replication event for the partitionId.

Overrides:

pollRandomWanEvent in class PublisherQueueContainer

Parameters:

partitionId - the partition ID for the replication event

Returns:

a random replication event for the given partition ID