com.atlassian.jira.cluster.distribution.localq

Class LocalQCacheManager

java.lang.Object

com.atlassian.jira.cluster.distribution.localq.LocalQCacheManager

public class LocalQCacheManager
extends Object

Stores all active queues LocalQCacheOpQueue and manages the queue readers LocalQCacheOpReader Service defined in ClusterServicesRegistrar only available in clustered jira and when LocalQConfig.isLocalQReplicationDisabled() is false.

Constructor Summary

Constructors

Constructor and Description
LocalQCacheManager(ClusterNodes clusterNodes, LocalQCacheOpSender localQCacheOpSender, LocalQCacheOpQueueFactory localQCacheOpQueueFactory, LocalQCriticalHandlerFactory localQCriticalHandlerFactory, com.atlassian.event.api.EventPublisher eventPublisher)

Method Summary

Modifier and Type	Method and Description
int	addToAllQueues(LocalQCacheOp localQCacheOp)
void	onNodeChangedEvent(NodeChangedEvent nodeChangedEvent)
void	onNodeJoinedClusterEvent(NodeJoinedClusterEvent nodeJoinedClusterEvent)
void	onNodeRemovedFromClusterEvent(NodeRemovedFromClusterEvent nodeRemovedFromClusterEvent)
void	onPluginFrameworkShutdownEvent(com.atlassian.plugin.event.events.PluginFrameworkShutdownEvent event)
void	onPluginFrameworkStartingEvent(com.atlassian.plugin.event.events.PluginFrameworkStartingEvent event)
Set<LocalQCacheOpQueueWithStats.QueueStats>	queueStatsTotal() Can be used to get the current statistics of cache replication local queues.
Set<LocalQCacheOpQueueWithStats.QueueStats>	queueStatsTotalMerged() Can be used to get the current statistics of cache replication local queues merged per destination node.
void	start() This is invoked before plugin system has been started.
void	stop() This is invoked after plugin system has been shut down.

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalQCacheManager

public LocalQCacheManager(ClusterNodes clusterNodes,
                          LocalQCacheOpSender localQCacheOpSender,
                          LocalQCacheOpQueueFactory localQCacheOpQueueFactory,
                          LocalQCriticalHandlerFactory localQCriticalHandlerFactory,
                          com.atlassian.event.api.EventPublisher eventPublisher)

Method Detail

onPluginFrameworkShutdownEvent

@EventListener
public void onPluginFrameworkShutdownEvent(com.atlassian.plugin.event.events.PluginFrameworkShutdownEvent event)

onPluginFrameworkStartingEvent

@EventListener
public void onPluginFrameworkStartingEvent(com.atlassian.plugin.event.events.PluginFrameworkStartingEvent event)

start

public void start()

This is invoked before plugin system has been started. See onPluginFrameworkStartingEvent(PluginFrameworkStartingEvent)

stop

public void stop()

This is invoked after plugin system has been shut down. See onPluginFrameworkShutdownEvent(PluginFrameworkShutdownEvent)

queueStatsTotal

@ExperimentalApi
public Set<LocalQCacheOpQueueWithStats.QueueStats> queueStatsTotal()

Can be used to get the current statistics of cache replication local queues. There will be LocalQConfig.NUMBER_OF_QUEUES_PER_NODE x (nodes-in-cluster - 1) LocalQCacheOpQueueWithStats.QueueStats returned.

Returns:

set of LocalQCacheOpQueueWithStats.QueueStats with stats per queue

queueStatsTotalMerged

@ExperimentalApi
public Set<LocalQCacheOpQueueWithStats.QueueStats> queueStatsTotalMerged()

Can be used to get the current statistics of cache replication local queues merged per destination node. There will be (nodes-in-cluster - 1) LocalQCacheOpQueueWithStats.QueueStats returned.

Returns:

set of LocalQCacheOpQueueWithStats.QueueStats with stats merged per node

onNodeChangedEvent

@EventListener
public void onNodeChangedEvent(NodeChangedEvent nodeChangedEvent)

onNodeJoinedClusterEvent

@EventListener
public void onNodeJoinedClusterEvent(NodeJoinedClusterEvent nodeJoinedClusterEvent)

onNodeRemovedFromClusterEvent

@EventListener
public void onNodeRemovedFromClusterEvent(NodeRemovedFromClusterEvent nodeRemovedFromClusterEvent)

addToAllQueues

public int addToAllQueues(LocalQCacheOp localQCacheOp)

Returns:

number of queues where LocalQCacheOp was added