com.hazelcast.map.impl.querycache.subscriber

Class SubscriberRegistry

java.lang.Object

com.hazelcast.map.impl.querycache.subscriber.SubscriberRegistry

All Implemented Interfaces:

Registry<String,Accumulator>

public class SubscriberRegistry
extends Object
implements Registry<String,Accumulator>

All registered subscriber side accumulators for an IMap can be reached from this registry class.

Every map has only one SubscriberRegistry.

Constructor Summary

Constructors

Constructor and Description
SubscriberRegistry(QueryCacheContext context, String mapName)

Method Summary

Modifier and Type	Method and Description
protected SubscriberAccumulatorFactory	createSubscriberAccumulatorFactory()
Map<String,Accumulator>	getAll() Returns map of all registered items in this registry.
protected QueryCacheContext	getContext()
Accumulator	getOrCreate(String cacheId) Returns item if it exists in this registry or creates it.
Accumulator	getOrNull(String cacheId) Returns item if it exists in this registry otherwise returns null.
Accumulator	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

SubscriberRegistry

public SubscriberRegistry(QueryCacheContext context,
                          String mapName)

Method Detail

getOrCreate

public Accumulator 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,Accumulator>

Parameters:

cacheId - key for reaching the item from this registry.

Returns:

registered item.

getOrNull

public Accumulator 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,Accumulator>

Parameters:

cacheId - key for reaching the item from this registry.

Returns:

registered item or null.

getAll

public Map<String,Accumulator> getAll()

Description copied from interface: Registry

Returns map of all registered items in this registry.

Specified by:

getAll in interface Registry<String,Accumulator>

Returns:

map of all registered items in this registry

remove

public Accumulator remove(String cacheId)

Description copied from interface: Registry

Removes the registration from this registry.

Specified by:

remove in interface Registry<String,Accumulator>

Parameters:

cacheId - key for reaching the item from this registry.

Returns:

removed registry entry.

createSubscriberAccumulatorFactory

protected SubscriberAccumulatorFactory createSubscriberAccumulatorFactory()

getContext

protected QueryCacheContext getContext()