Package com.atlassian.confluence.cache.hazelcast

Class AsyncInvalidationCacheFactory

java.lang.Object

com.atlassian.confluence.cache.hazelcast.AsyncInvalidationCacheFactory

@Internal
public final class AsyncInvalidationCacheFactory
extends Object

Responsible for creating AsyncInvalidationCache instances, as well as managing the scheduled publishing of sequence snapshots and observability events from those caches.

Since:

7.5

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AsyncInvalidationCacheFactory.CacheInvalidationOutOfSequenceEvent
static class	AsyncInvalidationCacheFactory.CacheSequenceSnapshotInconsistentEvent

Constructor Summary

Constructors

Constructor	Description
AsyncInvalidationCacheFactory(com.hazelcast.core.HazelcastInstance hazelcastInstance, com.atlassian.event.api.EventPublisher eventPublisher, com.atlassian.scheduler.SchedulerService schedulerService, com.atlassian.cache.CacheFactory localCacheFactory, io.micrometer.core.instrument.MeterRegistry micrometer)

Method Summary

Modifier and Type	Method	Description
<K,V> com.atlassian.cache.Cache<K,V>	createCache(String cacheName, com.atlassian.cache.CacheLoader loader, com.atlassian.cache.CacheSettings settings, com.atlassian.cache.hazelcast.HazelcastCacheManager hazelcastCacheManager)	Creates an instance of AsyncInvalidationCache, backed by the singleton instance of CacheInvalidatorFactory.
void	onTenantArrived(com.atlassian.tenancy.api.event.TenantArrivedEvent event)	Registers a sequence snapshot to be published on a scheduled, if and only if CacheInvalidatorFactory has been initialised.

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncInvalidationCacheFactory

public AsyncInvalidationCacheFactory(com.hazelcast.core.HazelcastInstance hazelcastInstance,
                                     com.atlassian.event.api.EventPublisher eventPublisher,
                                     com.atlassian.scheduler.SchedulerService schedulerService,
                                     com.atlassian.cache.CacheFactory localCacheFactory,
                                     io.micrometer.core.instrument.MeterRegistry micrometer)

Since:

7.6

Method Detail

onTenantArrived

@EventListener
public void onTenantArrived(com.atlassian.tenancy.api.event.TenantArrivedEvent event)
                     throws com.atlassian.scheduler.SchedulerServiceException

Registers a sequence snapshot to be published on a scheduled, if and only if CacheInvalidatorFactory has been initialised.

Throws:

com.atlassian.scheduler.SchedulerServiceException

createCache

public <K,V> com.atlassian.cache.Cache<K,V> createCache(String cacheName,
                                                                    com.atlassian.cache.CacheLoader loader,
                                                                    com.atlassian.cache.CacheSettings settings,
                                                                    com.atlassian.cache.hazelcast.HazelcastCacheManager hazelcastCacheManager)

Creates an instance of AsyncInvalidationCache, backed by the singleton instance of CacheInvalidatorFactory.