Package com.codebarrel.jira.plugin.automation.queue

Class JiraAutomationQueueStore

java.lang.Object

com.codebarrel.jira.plugin.automation.queue.JiraAutomationQueueStore

All Implemented Interfaces:

AutomationQueueStore

@Component
public class JiraAutomationQueueStore
extends Object
implements AutomationQueueStore

Constructor Summary

Constructors

Constructor	Description
JiraAutomationQueueStore(DbConnectionManager dbConnectionManager, ClusterManager clusterManager, FeatureFlagCache featureFlagCache)

Method Summary

Modifier and Type	Method	Description
long	addItem(Environment env, QueueItemBean queueItem)
List<Long>	addItems(Environment environment, List<QueueItemBean> items)
Optional<QueueItemBean>	claimItem(Environment env, String claimant, ClaimLimits claimLimits)
List<QueueItemBean>	claimItems(Environment env, String claimant, ClaimLimits claimLimits)
List<Long>	claimItemsById(Environment environment, String s, ClaimLimits claimLimits)
long	clearUnresolved(Environment env, Date date)
List<AutomationQueueInsightByRule>	getAutomationQueueInsightByRule(int limit)	Gets automation queue events grouped by rule.
long	getCount(Environment env)
long	getEarliestUnprocessedItemCreatedTime()
Optional<QueueItemBean>	getItem(Environment env, long id)
Optional<QueueItemBean>	getItemAndMarkForProcessing(Environment environment, long l)
long	getQueuedCountForAuditItem(Environment env, long auditItemId)
QueueStatistics	getStatistics(Environment environment)
boolean	isRuleInProgress(TenantContext context, long ruleId)
long	resolveItem(TenantExecution execution, long itemId)
Set<LegacyExecutionPair>	stopAllRuleExecutions(TenantContext context, long ruleId)	Stops the execution of an automation rule, and returns a set of all affected audit item ids (could be empty).
long	stopRuleExecution(TenantExecution execution)	Removes all items from the queue for this single rule execution.

Methods inherited from class java.lang.Object

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

Constructor Details

JiraAutomationQueueStore

@Inject
public JiraAutomationQueueStore(DbConnectionManager dbConnectionManager,
 ClusterManager clusterManager,
 FeatureFlagCache featureFlagCache)

Method Details

addItem

public long addItem(Environment env,
 QueueItemBean queueItem)

Specified by:

addItem in interface AutomationQueueStore

addItems

public List<Long> addItems(Environment environment,
 List<QueueItemBean> items)

Specified by:

addItems in interface AutomationQueueStore

claimItems

public List<QueueItemBean> claimItems(Environment env,
 String claimant,
 ClaimLimits claimLimits)

Specified by:

claimItems in interface AutomationQueueStore

claimItemsById

public List<Long> claimItemsById(Environment environment,
 String s,
 ClaimLimits claimLimits)

Specified by:

claimItemsById in interface AutomationQueueStore

claimItem

public Optional<QueueItemBean> claimItem(Environment env,
 String claimant,
 ClaimLimits claimLimits)

Specified by:

claimItem in interface AutomationQueueStore

resolveItem

public long resolveItem(TenantExecution execution,
 long itemId)

Specified by:

resolveItem in interface AutomationQueueStore

clearUnresolved

public long clearUnresolved(Environment env,
 Date date)

Specified by:

clearUnresolved in interface AutomationQueueStore

getStatistics

public QueueStatistics getStatistics(Environment environment)

Specified by:

getStatistics in interface AutomationQueueStore

getItem

public Optional<QueueItemBean> getItem(Environment env,
 long id)

Specified by:

getItem in interface AutomationQueueStore

getCount

public long getCount(Environment env)

Specified by:

getCount in interface AutomationQueueStore

getItemAndMarkForProcessing

public Optional<QueueItemBean> getItemAndMarkForProcessing(Environment environment,
 long l)

Specified by:

getItemAndMarkForProcessing in interface AutomationQueueStore

getQueuedCountForAuditItem

public long getQueuedCountForAuditItem(Environment env,
 long auditItemId)

Specified by:

getQueuedCountForAuditItem in interface AutomationQueueStore

stopAllRuleExecutions

public Set<LegacyExecutionPair> stopAllRuleExecutions(TenantContext context,
 long ruleId)

Description copied from interface: AutomationQueueStore

Stops the execution of an automation rule, and returns a set of all affected audit item ids (could be empty).

Specified by:

stopAllRuleExecutions in interface AutomationQueueStore

Parameters:

context - The tenant to execute this for

ruleId - The id of the rule to stop

Returns:

Set of audit item ids affected.

stopRuleExecution

public long stopRuleExecution(TenantExecution execution)

Description copied from interface: AutomationQueueStore

Removes all items from the queue for this single rule execution.

Specified by:

stopRuleExecution in interface AutomationQueueStore

Parameters:

execution - the execution to remove

Returns:

number of queued items removed

isRuleInProgress

public boolean isRuleInProgress(TenantContext context,
 long ruleId)

Specified by:

isRuleInProgress in interface AutomationQueueStore

getEarliestUnprocessedItemCreatedTime

public long getEarliestUnprocessedItemCreatedTime()

Specified by:

getEarliestUnprocessedItemCreatedTime in interface AutomationQueueStore

getAutomationQueueInsightByRule

public List<AutomationQueueInsightByRule> getAutomationQueueInsightByRule(int limit)

Description copied from interface: AutomationQueueStore

Gets automation queue events grouped by rule.

Specified by:

getAutomationQueueInsightByRule in interface AutomationQueueStore

Parameters:

limit - the number of groups to return

Returns:

the events grouped by rule