com.atlassian.cache.hazelcast.asyncinvalidation

Class AsyncInvalidationCache<K,V>

java.lang.Object

com.atlassian.cache.hazelcast.ManagedHybridCacheSupport

com.atlassian.cache.hazelcast.asyncinvalidation.AsyncInvalidationCache<K,V>

All Implemented Interfaces:

com.atlassian.cache.Cache<K,V>, com.atlassian.cache.ManagedCache

public final class AsyncInvalidationCache<K,V>
extends com.atlassian.cache.hazelcast.ManagedHybridCacheSupport
implements com.atlassian.cache.Cache<K,V>

An implementation of Cache that is backed by a local cache, and which publishes cache invalidation events when certain mutable operations are performed.

Field Summary

Fields inherited from class com.atlassian.cache.hazelcast.ManagedHybridCacheSupport

cacheManager, name

Constructor Summary

Constructors

Constructor and Description
AsyncInvalidationCache(String cacheName, com.atlassian.cache.hazelcast.HazelcastCacheManager cacheManager, com.atlassian.cache.Cache<K,V> localCache, com.atlassian.cache.ManagedCache localManagedCache, CacheInvalidator<K> invalidator)

Method Summary

Modifier and Type	Method and Description
void	addListener(com.atlassian.cache.CacheEntryListener<K,V> listener, boolean includeValues)
void	clear()
boolean	containsKey(K key)
V	get(K key)
V	get(K key, com.atlassian.cache.Supplier<? extends V> valueSupplier)
Map<K,V>	getBulk(Set<K> keys, Function<Set<K>,Map<K,V>> valuesSupplier)
Collection<K>	getKeys()
protected com.atlassian.cache.ManagedCache	getLocalCache()
boolean	isFlushable()
boolean	isReplicateAsynchronously()
void	put(K key, V value)
V	putIfAbsent(K key, V value)
void	remove(K key)
boolean	remove(K key, V value)
void	removeAll()
void	removeListener(com.atlassian.cache.CacheEntryListener<K,V> listener)
boolean	replace(K key, V oldValue, V newValue)

Methods inherited from class com.atlassian.cache.hazelcast.ManagedHybridCacheSupport

currentExpireAfterAccessMillis, currentExpireAfterWriteMillis, currentMaxEntries, getName, getStatistics, isLocal, isReplicateViaCopy, isStatisticsEnabled, setStatistics, updateExpireAfterAccess, updateExpireAfterWrite, updateMaxEntries

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.atlassian.cache.Cache

getName

Methods inherited from interface com.atlassian.cache.ManagedCache

getCacheCollector

Constructor Detail

AsyncInvalidationCache

public AsyncInvalidationCache(String cacheName,
                              com.atlassian.cache.hazelcast.HazelcastCacheManager cacheManager,
                              com.atlassian.cache.Cache<K,V> localCache,
                              com.atlassian.cache.ManagedCache localManagedCache,
                              CacheInvalidator<K> invalidator)

Method Detail

getLocalCache

protected com.atlassian.cache.ManagedCache getLocalCache()

Specified by:

getLocalCache in class com.atlassian.cache.hazelcast.ManagedHybridCacheSupport

clear

public void clear()

Specified by:

clear in interface com.atlassian.cache.ManagedCache

isFlushable

public boolean isFlushable()

Specified by:

isFlushable in interface com.atlassian.cache.ManagedCache

isReplicateAsynchronously

public boolean isReplicateAsynchronously()

Specified by:

isReplicateAsynchronously in interface com.atlassian.cache.ManagedCache

containsKey

public boolean containsKey(K key)

Specified by:

containsKey in interface com.atlassian.cache.Cache<K,V>

getKeys

public Collection<K> getKeys()

Specified by:

getKeys in interface com.atlassian.cache.Cache<K,V>

get

@Nullable
public V get(K key)

Specified by:

get in interface com.atlassian.cache.Cache<K,V>

get

public V get(K key,
             com.atlassian.cache.Supplier<? extends V> valueSupplier)

Specified by:

get in interface com.atlassian.cache.Cache<K,V>

getBulk

public Map<K,V> getBulk(Set<K> keys,
                        Function<Set<K>,Map<K,V>> valuesSupplier)

Specified by:

getBulk in interface com.atlassian.cache.Cache<K,V>

put

public void put(K key,
                V value)

Specified by:

put in interface com.atlassian.cache.Cache<K,V>

putIfAbsent

@Nullable
public V putIfAbsent(K key,
                               V value)

Specified by:

putIfAbsent in interface com.atlassian.cache.Cache<K,V>

remove

public void remove(K key)

Specified by:

remove in interface com.atlassian.cache.Cache<K,V>

remove

public boolean remove(K key,
                      V value)

Specified by:

remove in interface com.atlassian.cache.Cache<K,V>

removeAll

public void removeAll()

Specified by:

removeAll in interface com.atlassian.cache.Cache<K,V>

replace

public boolean replace(K key,
                       V oldValue,
                       V newValue)

Specified by:

replace in interface com.atlassian.cache.Cache<K,V>

addListener

public void addListener(com.atlassian.cache.CacheEntryListener<K,V> listener,
                        boolean includeValues)

Specified by:

addListener in interface com.atlassian.cache.Cache<K,V>

removeListener

public void removeListener(com.atlassian.cache.CacheEntryListener<K,V> listener)

Specified by:

removeListener in interface com.atlassian.cache.Cache<K,V>