com.hazelcast.enterprise.wan

Class PublisherQueueContainer

java.lang.Object

com.hazelcast.enterprise.wan.PublisherQueueContainer

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	clearQueues()
PartitionWanEventContainer	getPublisherEventQueue(int partitionId) Return 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) Poll the wan event queue for the cache with the name nameWithPrefix on partition partitionId.
com.hazelcast.wan.WanReplicationEvent	pollMapWanEvent(String mapName, int partitionId) Poll the wan event queue for the map with the name mapName on partition partitionId.
com.hazelcast.wan.WanReplicationEvent	pollRandomWanEvent(int partitionId) Return 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)

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)

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

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

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

Return the PartitionWanEventContainer for the specified partitionId

Parameters:

partitionId - the partition ID for the WAN event container

Returns:

the WAN event container

clearQueues

public void clearQueues()

size

public int size(int partitionId)