com.hazelcast.map.impl.querycache.publisher

Class PublisherRegistry

java.lang.Object

com.hazelcast.map.impl.querycache.publisher.PublisherRegistry

All Implemented Interfaces:

Registry<String,PartitionAccumulatorRegistry>

public class PublisherRegistry
extends Object
implements Registry<String,PartitionAccumulatorRegistry>

Registry of mappings like cacheId to PartitionAccumulatorRegistry.

See Also:

PartitionAccumulatorRegistry

Constructor Summary

Constructors

Constructor and Description
PublisherRegistry(QueryCacheContext context, String mapName)

Method Summary

Modifier and Type	Method and Description
protected PublisherAccumulatorFactory	createPublisherAccumulatorFactory()
Map<String,PartitionAccumulatorRegistry>	getAll() Returns map of all registered items in this registry.
PartitionAccumulatorRegistry	getOrCreate(String cacheId) Returns item if it exists in this registry or creates it.
PartitionAccumulatorRegistry	getOrNull(String cacheId) Returns item if it exists in this registry otherwise returns null.
PartitionAccumulatorRegistry	remove(String cacheId) Removes the registration from this registry.

Methods inherited from class java.lang.Object

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

Constructor Detail

PublisherRegistry

public PublisherRegistry(QueryCacheContext context,
                         String mapName)

Method Detail

getOrCreate

public PartitionAccumulatorRegistry getOrCreate(String cacheId)

Description copied from interface: Registry

Returns item if it exists in this registry or creates it.

Specified by:

getOrCreate in interface Registry<String,PartitionAccumulatorRegistry>

Parameters:

cacheId - key for reaching the item from this registry.

Returns:

registered item.

getOrNull

public PartitionAccumulatorRegistry getOrNull(String cacheId)

Description copied from interface: Registry

Returns item if it exists in this registry otherwise returns null.

Specified by:

getOrNull in interface Registry<String,PartitionAccumulatorRegistry>

Parameters:

cacheId - key for reaching the item from this registry.

Returns:

registered item or null.

getAll

public Map<String,PartitionAccumulatorRegistry> getAll()

Description copied from interface: Registry

Returns map of all registered items in this registry.

Specified by:

getAll in interface Registry<String,PartitionAccumulatorRegistry>

Returns:

map of all registered items in this registry

remove

public PartitionAccumulatorRegistry remove(String cacheId)

Description copied from interface: Registry

Removes the registration from this registry.

Specified by:

remove in interface Registry<String,PartitionAccumulatorRegistry>

Parameters:

cacheId - key for reaching the item from this registry.

Returns:

removed registry entry.

createPublisherAccumulatorFactory

protected PublisherAccumulatorFactory createPublisherAccumulatorFactory()