com.atlassian.cache.hazelcast

Class HazelcastCacheManager

java.lang.Object

com.atlassian.cache.impl.AbstractCacheManager

com.atlassian.cache.hazelcast.HazelcastCacheManager

All Implemented Interfaces:

CacheFactory, CacheManager

public class HazelcastCacheManager
extends AbstractCacheManager

Hazelcast implementation of the CacheManager contract

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	PREFIX
protected static String	PREFIX_CACHE
protected static String	PREFIX_CACHE_REFERENCE
protected static String	SETTINGS_MAP_NAME

Fields inherited from class com.atlassian.cache.impl.AbstractCacheManager

cacheCreationLocks, caches, cacheSettingsDefaultsProvider

Constructor Summary

Constructors

Constructor and Description
HazelcastCacheManager(com.hazelcast.core.HazelcastInstance hazelcast, CacheFactory localCacheFactory, CacheSettingsDefaultsProvider cacheSettingsDefaultsProvider)

Method Summary

Modifier and Type	Method and Description
protected void	checkSettingsAreCompatible(String name, CacheSettings settings)
protected com.hazelcast.config.MapConfig	configureMap(String mapName, CacheSettings settings)
protected <K,V> Cache<K,V>	createAsyncHybridCache(String name, CacheLoader<K,V> loader, CacheSettings settings)
protected <V> CachedReference<V>	createAsyncHybridCachedReference(String name, Supplier<V> supplier, CacheSettings settings)
protected <K,V> ManagedCache	createComputingCache(String name, CacheSettings settings, CacheLoader<K,V> loader) Creates a cache that upon a miss is able to populate itself using the loader.
protected <K,V> Cache<K,V>	createDistributedCache(String name, CacheLoader<K,V> loader, CacheSettings settings)
protected <V> CachedReference<V>	createDistributedCachedReference(String name, Supplier<V> supplier, CacheSettings settings)
protected <K,V> Cache<K,V>	createHybridCache(String name, CacheLoader<K,V> loader, CacheSettings settings)
protected <V> CachedReference<V>	createHybridCachedReference(String name, Supplier<V> supplier, CacheSettings settings)
protected ManagedCache	createSimpleCache(String name, CacheSettings settings) Creates a cache with no loader, i.e.
void	destroy() De-registers listeners.
<V> CachedReference<V>	getCachedReference(String name, Supplier<V> supplier, CacheSettings settings) Returns a Cached Reference, creating it if necessary.
com.hazelcast.core.HazelcastInstance	getHazelcastInstance()
void	init() Initializes the manager.
protected com.hazelcast.config.MapConfig	reconfigureMap(String mapName, CacheSettings newSettings)
boolean	updateCacheSettings(String mapName, CacheSettings newSettings) Update the cache settings of an existing cache.

Methods inherited from class com.atlassian.cache.impl.AbstractCacheManager

flushCaches, getCache, getCache, getCache, getCache, getCache, getCachedReference, getCachedReference, getCachedReference, getCaches, getManagedCache, getManagedCaches, mergeSettings, shutdown

Methods inherited from class java.lang.Object

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

Field Detail

PREFIX

protected static final String PREFIX

See Also:

Constant Field Values

PREFIX_CACHE

protected static final String PREFIX_CACHE

See Also:

Constant Field Values

PREFIX_CACHE_REFERENCE

protected static final String PREFIX_CACHE_REFERENCE

See Also:

Constant Field Values

SETTINGS_MAP_NAME

protected static final String SETTINGS_MAP_NAME

See Also:

Constant Field Values

Constructor Detail

HazelcastCacheManager

public HazelcastCacheManager(com.hazelcast.core.HazelcastInstance hazelcast,
                             CacheFactory localCacheFactory,
                             CacheSettingsDefaultsProvider cacheSettingsDefaultsProvider)

Method Detail

getHazelcastInstance

public com.hazelcast.core.HazelcastInstance getHazelcastInstance()

init

@PostConstruct
public void init()

Initializes the manager. This method must be called after the bean has been created.

createComputingCache

protected <K,V> ManagedCache createComputingCache(@Nonnull
                                                  String name,
                                                  @Nonnull
                                                  CacheSettings settings,
                                                  CacheLoader<K,V> loader)

Description copied from class: AbstractCacheManager

Creates a cache that upon a miss is able to populate itself using the loader.

Specified by:

createComputingCache in class AbstractCacheManager

Returns:

a non-null cache

createSimpleCache

protected ManagedCache createSimpleCache(@Nonnull
                                         String name,
                                         @Nonnull
                                         CacheSettings settings)

Description copied from class: AbstractCacheManager

Creates a cache with no loader, i.e. one populated via explicit puts.

Specified by:

createSimpleCache in class AbstractCacheManager

Parameters:

name - the name to give the cache (required)

Returns:

a non-null cache

destroy

@PreDestroy
public void destroy()

De-registers listeners. This method must be called when the bean is no longer required.

getCachedReference

@Nonnull
public <V> CachedReference<V> getCachedReference(@Nonnull
                                                          String name,
                                                          @Nonnull
                                                          Supplier<V> supplier,
                                                          @Nonnull
                                                          CacheSettings settings)

Description copied from interface: CacheFactory

Returns a Cached Reference, creating it if necessary.

Parameters:

name - the name of the Cached Reference

supplier - the supplier for value to be cached, called if the value needs to be generated

settings - specifies the required cache settings

Returns:

the Cached Reference

checkSettingsAreCompatible

protected void checkSettingsAreCompatible(String name,
                                          CacheSettings settings)

configureMap

protected com.hazelcast.config.MapConfig configureMap(String mapName,
                                                      CacheSettings settings)

reconfigureMap

protected com.hazelcast.config.MapConfig reconfigureMap(String mapName,
                                                        CacheSettings newSettings)

updateCacheSettings

public boolean updateCacheSettings(@Nonnull
                                   String mapName,
                                   @Nonnull
                                   CacheSettings newSettings)

Update the cache settings of an existing cache. Called by ManagedCache methods

Parameters:

mapName - The name of the map to update

newSettings - CacheSettings object representing the new settings

Returns:

true if the update succeeded, false otherwise

createAsyncHybridCache

protected <K,V> Cache<K,V> createAsyncHybridCache(String name,
                                                  CacheLoader<K,V> loader,
                                                  CacheSettings settings)

createAsyncHybridCachedReference

protected <V> CachedReference<V> createAsyncHybridCachedReference(String name,
                                                                  Supplier<V> supplier,
                                                                  CacheSettings settings)

createDistributedCache

protected <K,V> Cache<K,V> createDistributedCache(String name,
                                                  CacheLoader<K,V> loader,
                                                  CacheSettings settings)

createDistributedCachedReference

protected <V> CachedReference<V> createDistributedCachedReference(String name,
                                                                  Supplier<V> supplier,
                                                                  CacheSettings settings)

createHybridCache

protected <K,V> Cache<K,V> createHybridCache(String name,
                                             CacheLoader<K,V> loader,
                                             CacheSettings settings)

createHybridCachedReference

protected <V> CachedReference<V> createHybridCachedReference(String name,
                                                             Supplier<V> supplier,
                                                             CacheSettings settings)