Package com.atlassian.jira.cluster.distribution.localq
package com.atlassian.jira.cluster.distribution.localq
-
ClassDescriptionStores all active queues
LocalQCacheOpQueue
and manages the queue readersLocalQCacheOpReader
Service defined inClusterServicesRegistrar
only available in clustered jira and whenLocalQConfig.isLocalQReplicationDisabled()
is false.Represents a cache replication event in the local queue.Abstracts persistent queue implementation A queue represents a FIFO queue ofLocalQCacheOp
for a specific nodeNode
.Uniquely identifies a queueCreatesLocalQCacheOpQueue
for givenNode
and nodeQueueNumber so it is easy to switch to a different queue implementation.Statistics for the delegateLocalQCacheOpQueue
.Used to sendLocalQCacheOp
to remote node.Exception used by sender to signalLocalQCacheOp
could not be delivered, but should be retried "indefinitely".Exception used by sender to signalLocalQCacheOp
could not be delivered, but is "probably" a poison message and cannot be delivered now or ever.Contains all static configuration for LocalQ.Helper for handling critical situations like being unable to peek, add, remove from queue.Service defined incom.atlassian.jira.ClusterServicesRegistrar
only available in clustered jira and whenLocalQConfig.isLocalQReplicationDisabled()
is false.Utility class forLocalQCacheOpQueueWithStats.QueueStats
Used to generate: on INFO: total and snapshot statistics per node on DEBUG: total and snapshot statistics per node-queue