Class JiraAutomationQueueStore
java.lang.Object
com.codebarrel.jira.plugin.automation.queue.JiraAutomationQueueStore
- All Implemented Interfaces:
AutomationQueueStore
-
Constructor Summary
ConstructorsConstructorDescriptionJiraAutomationQueueStore(DbConnectionManager dbConnectionManager, ClusterManager clusterManager, FeatureFlagCache featureFlagCache) -
Method Summary
Modifier and TypeMethodDescriptionlongaddItem(Environment env, QueueItemBean queueItem) addItems(Environment environment, List<QueueItemBean> items) claimItem(Environment env, String claimant, ClaimLimits claimLimits) claimItems(Environment env, String claimant, ClaimLimits claimLimits) claimItemsById(Environment environment, String s, ClaimLimits claimLimits) longclearUnresolved(Environment env, Date date) getAutomationQueueInsightByRule(int limit) Gets automation queue events grouped by rule.longgetCount(Environment env) longgetItem(Environment env, long id) getItemAndMarkForProcessing(Environment environment, long l) longgetQueuedCountForAuditItem(Environment env, long auditItemId) getStatistics(Environment environment) booleanisRuleInProgress(TenantContext context, long ruleId) longresolveItem(TenantExecution execution, long itemId) 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).longstopRuleExecution(TenantExecution execution) Removes all items from the queue for this single rule execution.
-
Constructor Details
-
JiraAutomationQueueStore
@Inject public JiraAutomationQueueStore(DbConnectionManager dbConnectionManager, ClusterManager clusterManager, FeatureFlagCache featureFlagCache)
-
-
Method Details
-
addItem
- Specified by:
addItemin interfaceAutomationQueueStore
-
addItems
- Specified by:
addItemsin interfaceAutomationQueueStore
-
claimItems
- Specified by:
claimItemsin interfaceAutomationQueueStore
-
claimItemsById
- Specified by:
claimItemsByIdin interfaceAutomationQueueStore
-
claimItem
- Specified by:
claimItemin interfaceAutomationQueueStore
-
resolveItem
- Specified by:
resolveItemin interfaceAutomationQueueStore
-
clearUnresolved
- Specified by:
clearUnresolvedin interfaceAutomationQueueStore
-
getStatistics
- Specified by:
getStatisticsin interfaceAutomationQueueStore
-
getItem
- Specified by:
getItemin interfaceAutomationQueueStore
-
getCount
- Specified by:
getCountin interfaceAutomationQueueStore
-
getItemAndMarkForProcessing
- Specified by:
getItemAndMarkForProcessingin interfaceAutomationQueueStore
-
getQueuedCountForAuditItem
- Specified by:
getQueuedCountForAuditItemin interfaceAutomationQueueStore
-
stopAllRuleExecutions
Description copied from interface:AutomationQueueStoreStops the execution of an automation rule, and returns a set of all affected audit item ids (could be empty).- Specified by:
stopAllRuleExecutionsin interfaceAutomationQueueStore- Parameters:
context- The tenant to execute this forruleId- The id of the rule to stop- Returns:
- Set of audit item ids affected.
-
stopRuleExecution
Description copied from interface:AutomationQueueStoreRemoves all items from the queue for this single rule execution.- Specified by:
stopRuleExecutionin interfaceAutomationQueueStore- Parameters:
execution- the execution to remove- Returns:
- number of queued items removed
-
isRuleInProgress
- Specified by:
isRuleInProgressin interfaceAutomationQueueStore
-
getEarliestUnprocessedItemCreatedTime
public long getEarliestUnprocessedItemCreatedTime()- Specified by:
getEarliestUnprocessedItemCreatedTimein interfaceAutomationQueueStore
-
getAutomationQueueInsightByRule
Description copied from interface:AutomationQueueStoreGets automation queue events grouped by rule.- Specified by:
getAutomationQueueInsightByRulein interfaceAutomationQueueStore- Parameters:
limit- the number of groups to return- Returns:
- the events grouped by rule
-