com.hazelcast.cache.impl

Class HazelcastCacheManager

java.lang.Object

com.hazelcast.cache.impl.HazelcastCacheManager

All Implemented Interfaces:

Closeable, AutoCloseable, javax.cache.CacheManager

Direct Known Subclasses:

HazelcastClientCacheManager, HazelcastServerCacheManager

public abstract class HazelcastCacheManager
extends Object
implements javax.cache.CacheManager

The Hazelcast CacheManager base class. Hazelcast supports two modes:

• Client - HazelcastClientCacheManager
• Server - HazelcastServerCacheManager

See Also:

CacheManager

Field Summary

Fields

Modifier and Type	Field and Description
protected String	cacheNamePrefix
protected ConcurrentMap<String,ICache<?,?>>	caches
protected javax.cache.spi.CachingProvider	cachingProvider
protected WeakReference<ClassLoader>	classLoaderReference
protected HazelcastInstance	hazelcastInstance
protected boolean	isDefaultClassLoader
protected boolean	isDefaultURI
protected ILogger	logger
protected Properties	properties
protected URI	uri

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract <K,V> void	addCacheConfigIfAbsentToLocal(CacheConfig<K,V> cacheConfig)
protected String	cacheNamePrefix()
void	close()
<K,V,C extends javax.cache.configuration.Configuration<K,V>> javax.cache.Cache<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> ICache<K,V>	createCacheProxy(CacheConfig<K,V> cacheConfig)
protected abstract <K,V> boolean	createConfigOnPartition(CacheConfig<K,V> cacheConfig)
void	destroy() todo what does this do?
void	destroyCache(String cacheName)
<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>	getCacheConfigFromPartition(String cacheName)
protected abstract <K,V> CacheConfig<K,V>	getCacheConfigLocal(String cacheName)
Iterable<String>	getCacheNames()
protected String	getCacheNameWithPrefix(String name)
protected <K,V> ICache<?,?>	getCacheUnchecked(String cacheName)
javax.cache.spi.CachingProvider	getCachingProvider()
ClassLoader	getClassLoader()
Properties	getProperties()
URI	getURI()
boolean	isClosed()
protected <K,V> void	registerListeners(CacheConfig<K,V> cacheConfig, ICache<K,V> source)
protected void	removeCacheConfigFromLocal(String cacheName) todo Why is this empty?
String	toString()
<T> T	unwrap(Class<T> clazz)

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

Field Detail

caches

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

uri

protected final URI uri

classLoaderReference

protected final WeakReference<ClassLoader> classLoaderReference

properties

protected final Properties properties

cacheNamePrefix

protected final String cacheNamePrefix

isDefaultURI

protected final boolean isDefaultURI

isDefaultClassLoader

protected final boolean isDefaultClassLoader

logger

protected ILogger logger

cachingProvider

protected javax.cache.spi.CachingProvider cachingProvider

hazelcastInstance

protected HazelcastInstance hazelcastInstance

Constructor Detail

HazelcastCacheManager

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

Method Detail

createCache

public <K,V,C extends javax.cache.configuration.Configuration<K,V>> javax.cache.Cache<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

getCache

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

Specified by:

getCache in interface javax.cache.CacheManager

getCacheUnchecked

protected <K,V> ICache<?,?> getCacheUnchecked(String cacheName)

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

removeCacheConfigFromLocal

protected void removeCacheConfigFromLocal(String cacheName)

todo Why is this empty?

Parameters:

cacheName -

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

todo what does this do?

isClosed

public boolean isClosed()

Specified by:

isClosed in interface javax.cache.CacheManager

unwrap

public <T> T unwrap(Class<T> clazz)

Specified by:

unwrap in interface javax.cache.CacheManager

toString

public String toString()

Overrides:

toString in class Object

cacheNamePrefix

protected String cacheNamePrefix()

getCacheNameWithPrefix

protected String getCacheNameWithPrefix(String name)

createCacheConfig

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

getCacheConfigLocal

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

createConfigOnPartition

protected abstract <K,V> boolean createConfigOnPartition(CacheConfig<K,V> cacheConfig)

addCacheConfigIfAbsentToLocal

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

createCacheProxy

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

getCacheConfigFromPartition

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

registerListeners

protected <K,V> void registerListeners(CacheConfig<K,V> cacheConfig,
                           ICache<K,V> source)