Class RetryableAction<Response>

java.lang.Object
org.elasticsearch.action.support.RetryableAction<Response>

public abstract class RetryableAction<Response> extends Object
A action that will be retried on failure if shouldRetry(Exception) returns true. The executor the action will be executed on can be defined in the constructor. Otherwise, SAME is the default. The action will be retried with exponentially increasing delay periods until the timeout period has been reached.
  • Constructor Details

    • RetryableAction

      public RetryableAction(org.apache.logging.log4j.Logger logger, ThreadPool threadPool, org.elasticsearch.core.TimeValue initialDelay, org.elasticsearch.core.TimeValue timeoutValue, ActionListener<Response> listener)
    • RetryableAction

      public RetryableAction(org.apache.logging.log4j.Logger logger, ThreadPool threadPool, org.elasticsearch.core.TimeValue initialDelay, org.elasticsearch.core.TimeValue timeoutValue, ActionListener<Response> listener, String executor)
  • Method Details

    • run

      public void run()
    • cancel

      public void cancel(Exception e)
    • tryAction

      public abstract void tryAction(ActionListener<Response> listener)
    • shouldRetry

      public abstract boolean shouldRetry(Exception e)
    • calculateDelay

      protected long calculateDelay(long previousDelay)
    • minimumDelayMillis

      protected long minimumDelayMillis()
    • onFinished

      public void onFinished()