Package org.elasticsearch.action.support
Class RetryableAction<Response>
java.lang.Object
org.elasticsearch.action.support.RetryableAction<Response>
public abstract class RetryableAction<Response>
extends java.lang.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 Summary
Constructors Constructor Description RetryableAction(org.apache.logging.log4j.Logger logger, ThreadPool threadPool, TimeValue initialDelay, TimeValue timeoutValue, ActionListener<Response> listener)
RetryableAction(org.apache.logging.log4j.Logger logger, ThreadPool threadPool, TimeValue initialDelay, TimeValue timeoutValue, ActionListener<Response> listener, java.lang.String executor)
-
Method Summary
Modifier and Type Method Description void
cancel(java.lang.Exception e)
void
run()
abstract boolean
shouldRetry(java.lang.Exception e)
abstract void
tryAction(ActionListener<Response> listener)
-
Constructor Details
-
RetryableAction
public RetryableAction(org.apache.logging.log4j.Logger logger, ThreadPool threadPool, TimeValue initialDelay, TimeValue timeoutValue, ActionListener<Response> listener) -
RetryableAction
public RetryableAction(org.apache.logging.log4j.Logger logger, ThreadPool threadPool, TimeValue initialDelay, TimeValue timeoutValue, ActionListener<Response> listener, java.lang.String executor)
-
-
Method Details
-
run
public void run() -
cancel
public void cancel(java.lang.Exception e) -
tryAction
-
shouldRetry
public abstract boolean shouldRetry(java.lang.Exception e)
-