com.atlassian.jira.cluster

Class CuttingOffExecutorImpl

java.lang.Object

com.atlassian.jira.cluster.CuttingOffExecutorImpl

All Implemented Interfaces:

CuttingOffExecutor

@ThreadSafe
public class CuttingOffExecutorImpl
extends Object
implements CuttingOffExecutor

An implementation of cutting off executor that will cut off any further executions after registering first failure. It has a retry mechanism with exponential backoff limited to maximum of 5 minutes between reties. There can be only one retry performed at any given moment.

Since:

v7.2.12

Nested Class Summary

Nested classes/interfaces inherited from interface com.atlassian.jira.cluster.CuttingOffExecutor

CuttingOffExecutor.Callback, CuttingOffExecutor.Invoke<T>

Constructor Summary

Constructors

Constructor and Description
CuttingOffExecutorImpl(java.time.Clock clock, Node node, com.atlassian.event.api.EventPublisher eventPublisher, ClusterManager clusterManager)

Method Summary

Modifier and Type	Method and Description
<T> Optional<T>	invokeOrCutOff(CuttingOffExecutor.Invoke<T> invoke) Code provided as invoke will be invoked and returned object of type T will be wrapped and returned as Optional or supplied invoke will not be executed and Optional.empty() will be returned

Methods inherited from class java.lang.Object

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

Constructor Detail

CuttingOffExecutorImpl

public CuttingOffExecutorImpl(java.time.Clock clock,
                              Node node,
                              com.atlassian.event.api.EventPublisher eventPublisher,
                              ClusterManager clusterManager)

Method Detail

invokeOrCutOff

@Nonnull
public <T> Optional<T> invokeOrCutOff(@Nonnull
                                               CuttingOffExecutor.Invoke<T> invoke)

Description copied from interface: CuttingOffExecutor

Code provided as invoke will be invoked and returned object of type T will be wrapped and returned as Optional or supplied invoke will not be executed and Optional.empty() will be returned

Specified by:

invokeOrCutOff in interface CuttingOffExecutor

Parameters:

invoke - implementation of CuttingOffExecutor.Invoke functional interface that describe operation that should be invoked or cut off and skipped.

Returns:

value returned as result of calling invoke or Optional.empty() if invoke was not called