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 and Description
static class	AsyncInvalidationCacheFactory.CacheInvalidationOutOfSequenceEvent
static class	AsyncInvalidationCacheFactory.CacheSequenceSnapshotInconsistentEvent

Constructor Summary

Constructors

Constructor and 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 and 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.