com.hazelcast.cache.impl

Class AbstractHazelcastCacheManager

java.lang.Object

com.hazelcast.cache.impl.AbstractHazelcastCacheManager

All Implemented Interfaces:

HazelcastCacheManager, Closeable, AutoCloseable, javax.cache.CacheManager

Direct Known Subclasses:

HazelcastClientCacheManager, HazelcastServerCacheManager

public abstract class AbstractHazelcastCacheManager
extends Object
implements HazelcastCacheManager

Abstract HazelcastCacheManager (also indirect CacheManager) implementation to provide shared functionality to server and client cache managers.

There are two cache managers which can be accessed via their providers:

• Client: HazelcastClientCacheManager
• Server: HazelcastServerCacheManager

AbstractHazelcastCacheManager manages the lifecycle of the caches created or accessed through itself.

See Also:

HazelcastCacheManager, CacheManager

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentMap<String,ICacheInternal<?,?>>	caches
protected javax.cache.spi.CachingProvider	cachingProvider
protected HazelcastInstance	hazelcastInstance
protected boolean	isDefaultClassLoader
protected boolean	isDefaultURI
protected Properties	properties
protected URI	uri

Fields inherited from interface com.hazelcast.cache.HazelcastCacheManager

CACHE_MANAGER_PREFIX

Constructor Summary

Constructors

Constructor and Description
AbstractHazelcastCacheManager(javax.cache.spi.CachingProvider cachingProvider, HazelcastInstance hazelcastInstance, URI uri, ClassLoader classLoader, Properties properties)

Method Summary

Modifier and Type	Method and Description
protected abstract <K,V> void	addCacheConfigIfAbsent(CacheConfig<K,V> cacheConfig)
void	close()
<K,V,C extends javax.cache.configuration.Configuration<K,V>> ICache<K,V>	createCache(String cacheName, C configuration)
protected <K,V,C extends javax.cache.configuration.Configuration<K,V>> CacheConfig<K,V>	createCacheConfig(String cacheName, C configuration)
protected abstract <K,V> void	createCacheConfig(String cacheName, CacheConfig<K,V> config)
protected abstract <K,V> ICacheInternal<K,V>	createCacheProxy(CacheConfig<K,V> cacheConfig)
void	destroy() Destroys all managed caches.
void	destroyCache(String cacheName)
protected void	ensureOpen()
protected abstract <K,V> CacheConfig<K,V>	findCacheConfig(String cacheName, String simpleCacheName)
<K,V> ICache<K,V>	getCache(String cacheName)
<K,V> ICache<K,V>	getCache(String cacheName, Class<K> keyType, Class<V> valueType)
protected abstract <K,V> CacheConfig<K,V>	getCacheConfig(String cacheName, String simpleCacheName)
Iterable<String>	getCacheNames()
String	getCacheNameWithPrefix(String name) Gets the cache name by adding the manager prefix.
javax.cache.spi.CachingProvider	getCachingProvider()
ClassLoader	getClassLoader()
HazelcastInstance	getHazelcastInstance() Gets the underlying HazelcastInstance implementation.
<K,V> ICache<K,V>	getOrCreateCache(String cacheName, CacheConfig<K,V> cacheConfig)
Properties	getProperties()
URI	getURI()
boolean	isClosed()
protected abstract void	onShuttingDown()
protected abstract void	postClose()
protected void	postDestroy()
void	removeCache(String cacheName, boolean destroy) Removes the associated cache with the given cache name.
protected void	removeCacheConfigFromLocal(String cacheNameWithPrefix) Removes the local copy of the cache configuration if one exists.
String	toString()
protected abstract <K,V> void	validateCacheConfig(CacheConfig<K,V> cacheConfig)

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.cache.CacheManager

enableManagement, enableStatistics, unwrap

Field Detail

caches

protected final ConcurrentMap<String,ICacheInternal<?,?>> caches

cachingProvider

protected final javax.cache.spi.CachingProvider cachingProvider

hazelcastInstance

protected final HazelcastInstance hazelcastInstance

isDefaultURI

protected final boolean isDefaultURI

isDefaultClassLoader

protected final boolean isDefaultClassLoader

uri

protected final URI uri

properties

protected final Properties properties

Constructor Detail

AbstractHazelcastCacheManager

public AbstractHazelcastCacheManager(javax.cache.spi.CachingProvider cachingProvider,
                                     HazelcastInstance hazelcastInstance,
                                     URI uri,
                                     ClassLoader classLoader,
                                     Properties properties)

Method Detail

getHazelcastInstance

public HazelcastInstance getHazelcastInstance()

Description copied from interface: HazelcastCacheManager

Gets the underlying HazelcastInstance implementation.

Specified by:

getHazelcastInstance in interface HazelcastCacheManager

Returns:

the underlying HazelcastInstance implementation

createCache

public <K,V,C extends javax.cache.configuration.Configuration<K,V>> ICache<K,V> createCache(String cacheName,
                                                                                            C configuration)
                                                                                     throws IllegalArgumentException

Specified by:

createCache in interface javax.cache.CacheManager

Throws:

IllegalArgumentException

getCachingProvider

public javax.cache.spi.CachingProvider getCachingProvider()

Specified by:

getCachingProvider in interface javax.cache.CacheManager

getURI

public URI getURI()

Specified by:

getURI in interface javax.cache.CacheManager

getClassLoader

public ClassLoader getClassLoader()

Specified by:

getClassLoader in interface javax.cache.CacheManager

getProperties

public Properties getProperties()

Specified by:

getProperties in interface javax.cache.CacheManager

getCache

public <K,V> ICache<K,V> getCache(String cacheName,
                                  Class<K> keyType,
                                  Class<V> valueType)

Specified by:

getCache in interface javax.cache.CacheManager

getOrCreateCache

public <K,V> ICache<K,V> getOrCreateCache(String cacheName,
                                          CacheConfig<K,V> cacheConfig)

getCache

public <K,V> ICache<K,V> getCache(String cacheName)

Specified by:

getCache in interface javax.cache.CacheManager

getCacheNames

public Iterable<String> getCacheNames()

Specified by:

getCacheNames in interface javax.cache.CacheManager

destroyCache

public void destroyCache(String cacheName)

Specified by:

destroyCache in interface javax.cache.CacheManager

removeCache

public void removeCache(String cacheName,
                        boolean destroy)

Description copied from interface: HazelcastCacheManager

Removes the associated cache with the given cache name.

Specified by:

removeCache in interface HazelcastCacheManager

Parameters:

cacheName - pure cache name without prefix

destroy - flag to specify whether the removed cache will be destroyed

removeCacheConfigFromLocal

protected void removeCacheConfigFromLocal(String cacheNameWithPrefix)

Removes the local copy of the cache configuration if one exists.

The default implementation does not require it, but client implementation overrides this to track a local copy of the config.

Parameters:

cacheNameWithPrefix - the cache name

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface javax.cache.CacheManager

destroy

public void destroy()

Destroys all managed caches.

Specified by:

destroy in interface HazelcastCacheManager

postDestroy

protected void postDestroy()

isClosed

public boolean isClosed()

Specified by:

isClosed in interface javax.cache.CacheManager

ensureOpen

protected void ensureOpen()

getCacheNameWithPrefix

public String getCacheNameWithPrefix(String name)

Description copied from interface: HazelcastCacheManager

Gets the cache name by adding the manager prefix.

Specified by:

getCacheNameWithPrefix in interface HazelcastCacheManager

Parameters:

name - pure cache name without prefix

Returns:

the cache name with manager prefix

createCacheConfig

protected <K,V,C extends javax.cache.configuration.Configuration<K,V>> CacheConfig<K,V> createCacheConfig(String cacheName,
                                                                                                          C configuration)

toString

public String toString()

Overrides:

toString in class Object

validateCacheConfig

protected abstract <K,V> void validateCacheConfig(CacheConfig<K,V> cacheConfig)

addCacheConfigIfAbsent

protected abstract <K,V> void addCacheConfigIfAbsent(CacheConfig<K,V> cacheConfig)

createCacheProxy

protected abstract <K,V> ICacheInternal<K,V> createCacheProxy(CacheConfig<K,V> cacheConfig)

findCacheConfig

protected abstract <K,V> CacheConfig<K,V> findCacheConfig(String cacheName,
                                                          String simpleCacheName)

createCacheConfig

protected abstract <K,V> void createCacheConfig(String cacheName,
                                                CacheConfig<K,V> config)

getCacheConfig

protected abstract <K,V> CacheConfig<K,V> getCacheConfig(String cacheName,
                                                         String simpleCacheName)

postClose

protected abstract void postClose()

onShuttingDown

protected abstract void onShuttingDown()