com.atlassian.confluence.impl.cache.hibernate

Class HibernateClusterAwareCacheManager

java.lang.Object

com.atlassian.confluence.impl.cache.hibernate.HibernateClusterAwareCacheManager

All Implemented Interfaces:

com.atlassian.cache.CacheFactory, com.atlassian.cache.CacheManager, org.springframework.beans.factory.InitializingBean

@Internal
public class HibernateClusterAwareCacheManager
extends Object
implements com.atlassian.cache.CacheManager, org.springframework.beans.factory.InitializingBean

Make sure Hibernate L2 caches are flushed correctly in Data Center. In Data Center, Hibernate L2 caches are backed by Hazelcast and are divided into multiple regions. By default, all these regions are stored as distributed IMaps except for query cache region which is stored locally on each node thus not managed by CacheManager. Due to how query caching works in Hibernate, query caches *must* always be flushed whenever timestamp caches are flushed. This class publishes a cluster event to flush query caches on *each* node when timestamp caches are flushed via CacheManager

Since:

6.14

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
void	flushCaches()
<K,V> com.atlassian.cache.Cache<K,V>	getCache(Class<?> owningClass, String name)
<K,V> com.atlassian.cache.Cache<K,V>	getCache(String name)
<K,V> com.atlassian.cache.Cache<K,V>	getCache(String name, com.atlassian.cache.CacheLoader<K,V> loader)
<K,V> com.atlassian.cache.Cache<K,V>	getCache(String name, com.atlassian.cache.CacheLoader<K,V> loader, com.atlassian.cache.CacheSettings required)
<K,V> com.atlassian.cache.Cache<K,V>	getCache(String name, Class<K> keyType, Class<V> valueType)
<V> com.atlassian.cache.CachedReference<V>	getCachedReference(Class<?> owningClass, String name, com.atlassian.cache.Supplier<V> supplier)
<V> com.atlassian.cache.CachedReference<V>	getCachedReference(Class<?> owningClass, String name, com.atlassian.cache.Supplier<V> supplier, com.atlassian.cache.CacheSettings required)
<V> com.atlassian.cache.CachedReference<V>	getCachedReference(String name, com.atlassian.cache.Supplier<V> supplier)
<V> com.atlassian.cache.CachedReference<V>	getCachedReference(String name, com.atlassian.cache.Supplier<V> supplier, com.atlassian.cache.CacheSettings required)
Collection<com.atlassian.cache.Cache<?,?>>	getCaches()
com.atlassian.cache.ManagedCache	getManagedCache(String name)
Collection<com.atlassian.cache.ManagedCache>	getManagedCaches()
void	onClusterCacheFlush(ClusterEventWrapper wrapper) Timestamp cache region has been flushed, time to flush all local query caches.
void	shutdown()

Methods inherited from class java.lang.Object

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

Method Detail

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

Exception

onClusterCacheFlush

@EventListener
public void onClusterCacheFlush(ClusterEventWrapper wrapper)

Timestamp cache region has been flushed, time to flush all local query caches. Due to nature of cluster events, nodes other than the flush triggering node may have staled data until this event is propagated to them. In rare circumstances, this event may even not be delivered altogether. In that case, Hibernate optimistic locking is our last defence.

getCaches

@Nonnull
public Collection<com.atlassian.cache.Cache<?,?>> getCaches()

Specified by:

getCaches in interface com.atlassian.cache.CacheManager

getManagedCaches

@Nonnull
public Collection<com.atlassian.cache.ManagedCache> getManagedCaches()

Specified by:

getManagedCaches in interface com.atlassian.cache.CacheManager

flushCaches

public void flushCaches()

Specified by:

flushCaches in interface com.atlassian.cache.CacheManager

getManagedCache

@Nullable
public com.atlassian.cache.ManagedCache getManagedCache(@Nonnull
                                                                  String name)

Specified by:

getManagedCache in interface com.atlassian.cache.CacheManager

shutdown

public void shutdown()

Specified by:

shutdown in interface com.atlassian.cache.CacheManager

getCachedReference

@Nonnull
public <V> com.atlassian.cache.CachedReference<V> getCachedReference(@Nonnull
                                                                              String name,
                                                                              @Nonnull
                                                                              com.atlassian.cache.Supplier<V> supplier)

Specified by:

getCachedReference in interface com.atlassian.cache.CacheFactory

getCachedReference

@Nonnull
public <V> com.atlassian.cache.CachedReference<V> getCachedReference(@Nonnull
                                                                              String name,
                                                                              @Nonnull
                                                                              com.atlassian.cache.Supplier<V> supplier,
                                                                              @Nonnull
                                                                              com.atlassian.cache.CacheSettings required)

Specified by:

getCachedReference in interface com.atlassian.cache.CacheFactory

getCachedReference

@Nonnull
public <V> com.atlassian.cache.CachedReference<V> getCachedReference(@Nonnull
                                                                              Class<?> owningClass,
                                                                              @Nonnull
                                                                              String name,
                                                                              @Nonnull
                                                                              com.atlassian.cache.Supplier<V> supplier)

Specified by:

getCachedReference in interface com.atlassian.cache.CacheFactory

getCachedReference

@Nonnull
public <V> com.atlassian.cache.CachedReference<V> getCachedReference(@Nonnull
                                                                              Class<?> owningClass,
                                                                              @Nonnull
                                                                              String name,
                                                                              @Nonnull
                                                                              com.atlassian.cache.Supplier<V> supplier,
                                                                              @Nonnull
                                                                              com.atlassian.cache.CacheSettings required)

Specified by:

getCachedReference in interface com.atlassian.cache.CacheFactory

getCache

@Nonnull
public <K,V> com.atlassian.cache.Cache<K,V> getCache(@Nonnull
                                                              String name)

Specified by:

getCache in interface com.atlassian.cache.CacheFactory

getCache

@Nonnull
public <K,V> com.atlassian.cache.Cache<K,V> getCache(@Nonnull
                                                              Class<?> owningClass,
                                                              @Nonnull
                                                              String name)

Specified by:

getCache in interface com.atlassian.cache.CacheFactory

getCache

@Nonnull
public <K,V> com.atlassian.cache.Cache<K,V> getCache(@Nonnull
                                                              String name,
                                                              @Nullable
                                                              com.atlassian.cache.CacheLoader<K,V> loader)

Specified by:

getCache in interface com.atlassian.cache.CacheFactory

getCache

@Nonnull
public <K,V> com.atlassian.cache.Cache<K,V> getCache(@Nonnull
                                                              String name,
                                                              @Nullable
                                                              com.atlassian.cache.CacheLoader<K,V> loader,
                                                              @Nonnull
                                                              com.atlassian.cache.CacheSettings required)

Specified by:

getCache in interface com.atlassian.cache.CacheFactory

getCache

@Nonnull
public <K,V> com.atlassian.cache.Cache<K,V> getCache(@Nonnull
                                                              String name,
                                                              @Nonnull
                                                              Class<K> keyType,
                                                              @Nonnull
                                                              Class<V> valueType)

Specified by:

getCache in interface com.atlassian.cache.CacheFactory