org.infinispan.registry

Class ClusterRegistryImpl<S,K,V>

java.lang.Object

org.infinispan.registry.ClusterRegistryImpl<S,K,V>

All Implemented Interfaces:

ClusterRegistry<S,K,V>

@ThreadSafe
public class ClusterRegistryImpl<S,K,V>
extends Object
implements ClusterRegistry<S,K,V>

Default implementation of the ClusterRegistry. Stores all the information in a replicated cache that is lazily instantiated on the first access. This means that if the EmbeddedCacheManager doesn't use the metadata the underlaying cache never gets instantiated.

Since:

6.0

Author:

Mircea Markus

Field Summary

Fields

Modifier and Type	Field and Description
static String	GLOBAL_REGISTRY_CACHE_NAME

Constructor Summary

Constructors

Constructor and Description
ClusterRegistryImpl()

Method Summary

Modifier and Type	Method and Description
void	addListener(S scope, KeyFilter keyFilter, Object listener) Adds a listener that is notified of changes to keys in a given scope and which match a given KeyFilter.
void	addListener(S scope, Object listener) Adds a listener that is notified of changes to keys in a given scope.
void	clear(S scope)
void	clearAll()
boolean	containsKey(S scope, K key)
V	get(S scope, K key)
void	init(EmbeddedCacheManager cacheManager)
Set<K>	keys(S scope)
V	put(S scope, K key, V value)
V	remove(S scope, K key)
void	removeListener(Object listener) Detaches a listener instance.

Methods inherited from class java.lang.Object

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

Field Detail

GLOBAL_REGISTRY_CACHE_NAME

public static final String GLOBAL_REGISTRY_CACHE_NAME

See Also:

Constant Field Values

Constructor Detail

ClusterRegistryImpl

public ClusterRegistryImpl()

Method Detail

init

public void init(EmbeddedCacheManager cacheManager)

put

public V put(S scope,
             K key,
             V value)

Specified by:

put in interface ClusterRegistry<S,K,V>

remove

public V remove(S scope,
                K key)

Specified by:

remove in interface ClusterRegistry<S,K,V>

get

public V get(S scope,
             K key)

Specified by:

get in interface ClusterRegistry<S,K,V>

containsKey

public boolean containsKey(S scope,
                           K key)

Specified by:

containsKey in interface ClusterRegistry<S,K,V>

keys

public Set<K> keys(S scope)

Specified by:

keys in interface ClusterRegistry<S,K,V>

clear

public void clear(S scope)

Specified by:

clear in interface ClusterRegistry<S,K,V>

clearAll

public void clearAll()

Specified by:

clearAll in interface ClusterRegistry<S,K,V>

addListener

public void addListener(S scope,
                        Object listener)

Description copied from interface: ClusterRegistry

Adds a listener that is notified of changes to keys in a given scope.

Specified by:

addListener in interface ClusterRegistry<S,K,V>

Parameters:

scope - the scope to watch

listener - a properly annotated listener instance

addListener

public void addListener(S scope,
                        KeyFilter keyFilter,
                        Object listener)

Description copied from interface: ClusterRegistry

Adds a listener that is notified of changes to keys in a given scope and which match a given KeyFilter.

Specified by:

addListener in interface ClusterRegistry<S,K,V>

Parameters:

scope - the scope to watch

listener - a properly annotated listener instance

removeListener

public void removeListener(Object listener)

Description copied from interface: ClusterRegistry

Detaches a listener instance.

Specified by:

removeListener in interface ClusterRegistry<S,K,V>

Parameters:

listener - the listener to detach