Add a maxRetriesExceededHandler to the MaxRetriesFailureHandler

[piotrooo]

Hello!

What do you think about add a maxRetriesExceededHandler feature to the MaxRetriesFailureHandler. The reason behind this feature is to act some action when retries handler is exceeded. That's could be a simple consumer (BiConsumer - we have to pass a ExecutionComplete and ExecutionOperations).
Default value should be a noop consumer.

PoC:

class MaxRetriesFailureHandler<T> implements FailureHandler<T> {
    private static final Logger LOG = LoggerFactory.getLogger(MaxRetriesFailureHandler.class);
    private final int maxRetries;
    private final FailureHandler<T> failureHandler;
    private final BiConsumer<ExecutionComplete, ExecutionOperations<T>> maxRetriesExceededHandler;

    public MaxRetriesFailureHandler(int maxRetries, FailureHandler<T> failureHandler) {
        this(maxRetries, failureHandler, (executionComplete, executionOperations) -> {
        });
    }

    public MaxRetriesFailureHandler(int maxRetries, FailureHandler<T> failureHandler, BiConsumer<ExecutionComplete, ExecutionOperations<T>> maxRetriesExceededHandler) {
        this.maxRetries = maxRetries;
        this.failureHandler = failureHandler;
        this.maxRetriesExceededHandler = maxRetriesExceededHandler;
    }

    @Override
    public void onFailure(
            final ExecutionComplete executionComplete,
            final ExecutionOperations<T> executionOperations) {
        int consecutiveFailures = executionComplete.getExecution().consecutiveFailures;
        int totalNumberOfFailures = consecutiveFailures + 1;
        if (totalNumberOfFailures > maxRetries) {
            LOG.error(
                    "Execution has failed {} times for task instance {}. Cancelling execution.",
                    totalNumberOfFailures,
                    executionComplete.getExecution().taskInstance);
            executionOperations.stop();
            maxRetriesExceededHandler.accept(executionComplete, executionOperations);
        } else {
            this.failureHandler.onFailure(executionComplete, executionOperations);
        }
    }
}

Thanks for a great library!

[piotrooo]

@kagkarlsson gently ping.

[kagkarlsson]

I think that sounds like a good idea, yeah 👍

[piotrooo]

I have created that internally, so if you can convert this discussion to the issue I can implement it.

[kagkarlsson]

#396