com.atlassian.confluence.cache.hazelcast.monitoring

Class DistributedCacheInvalidationCounter<M>

java.lang.Object

com.atlassian.confluence.cache.hazelcast.monitoring.DistributedCacheInvalidationCounter<M>

public abstract class DistributedCacheInvalidationCounter<M>
extends Object

Responsible for counting distributed cache invalidation messages published on Hazelcast ITopics, using Micrometer. This is an abstract class, and subclasses are responsible for determining which topics are used, and how to decode the messages on them.

See Also:

HazelcastTopicMessageRouter

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	DistributedCacheInvalidationCounter.InvalidationType

Constructor Summary

Constructors

Constructor and Description
DistributedCacheInvalidationCounter(HazelcastTopicMessageRouter messageRouter, io.micrometer.core.instrument.MeterRegistry meterRegistry, com.atlassian.event.api.EventListenerRegistrar eventListenerRegistrar)

Method Summary

Modifier and Type	Method and Description
protected abstract String	cacheType()
static DistributedCacheInvalidationCounter<Object>	forAtlassianCache(com.atlassian.cache.CacheManager cacheManager, HazelcastTopicMessageRouter messageRouter, io.micrometer.core.instrument.MeterRegistry meterRegistry, com.atlassian.event.api.EventListenerRegistrar eventListenerRegistrar) Creates a DistributedCacheInvalidationCounter that counts invalidations published by HazelcastAsyncHybridCache.
static DistributedCacheInvalidationCounter<com.hazelcast.hibernate.local.Invalidation>	forHibernateL2CacheRegions(org.hibernate.SessionFactory sessionFactory, HazelcastTopicMessageRouter messageRouter, io.micrometer.core.instrument.MeterRegistry meterRegistry, com.atlassian.event.api.EventListenerRegistrar eventListenerRegistrar) Creates a DistributedCacheInvalidationCounter that counts invalidations published by LocalRegionCache via HazelcastHibernateRegionFactory.
protected abstract String	getCacheName(String topicName)
protected abstract Stream<String>	getInvalidationTopicNames()
protected abstract DistributedCacheInvalidationCounter.InvalidationType	invalidationType(M message)
void	onTenantArrived(com.atlassian.tenancy.api.event.TenantArrivedEvent event)
void	registerForTenantArrivalEvent()
void	unregisterFromEvents()

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedCacheInvalidationCounter

public DistributedCacheInvalidationCounter(HazelcastTopicMessageRouter messageRouter,
                                           io.micrometer.core.instrument.MeterRegistry meterRegistry,
                                           com.atlassian.event.api.EventListenerRegistrar eventListenerRegistrar)

Method Detail

registerForTenantArrivalEvent

@PostConstruct
public void registerForTenantArrivalEvent()

unregisterFromEvents

@PreDestroy
public void unregisterFromEvents()

onTenantArrived

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

getInvalidationTopicNames

protected abstract Stream<String> getInvalidationTopicNames()

cacheType

protected abstract String cacheType()

getCacheName

protected abstract String getCacheName(String topicName)

invalidationType

protected abstract DistributedCacheInvalidationCounter.InvalidationType invalidationType(M message)

forHibernateL2CacheRegions

public static DistributedCacheInvalidationCounter<com.hazelcast.hibernate.local.Invalidation> forHibernateL2CacheRegions(org.hibernate.SessionFactory sessionFactory,
                                                                                                                         HazelcastTopicMessageRouter messageRouter,
                                                                                                                         io.micrometer.core.instrument.MeterRegistry meterRegistry,
                                                                                                                         com.atlassian.event.api.EventListenerRegistrar eventListenerRegistrar)

Creates a DistributedCacheInvalidationCounter that counts invalidations published by LocalRegionCache via HazelcastHibernateRegionFactory.

forAtlassianCache

public static DistributedCacheInvalidationCounter<Object> forAtlassianCache(com.atlassian.cache.CacheManager cacheManager,
                                                                            HazelcastTopicMessageRouter messageRouter,
                                                                            io.micrometer.core.instrument.MeterRegistry meterRegistry,
                                                                            com.atlassian.event.api.EventListenerRegistrar eventListenerRegistrar)

Creates a DistributedCacheInvalidationCounter that counts invalidations published by HazelcastAsyncHybridCache.