Package org.elasticsearch.action

Class ActionRunnable<Response>

org.elasticsearch.common.util.concurrent.AbstractRunnable

org.elasticsearch.action.ActionRunnable<Response>

All Implemented Interfaces:

public abstract class ActionRunnable<Response>
extends AbstractRunnable

Base class for s that need to call ActionListener.onFailure(Exception) in case an uncaught exception or error is thrown while the actual action is run.

Field Summary

Fields

Modifier and Type	Field	Description
protected ActionListener<Response>	listener

Constructor Summary

Constructors

Constructor	Description
ActionRunnable(ActionListener<Response> listener)

Method Summary

Modifier and Type	Method	Description
void	e)	Calls the action listeners ActionListener.onFailure(Exception) method with the given exception.
static <T> ActionRunnable<T>	run(ActionListener<T> listener, org.elasticsearch.core.CheckedRunnable<> runnable)	Creates a that invokes the given listener with null after the given runnable has executed.
static <T> ActionRunnable<T>	supply(ActionListener<T> listener, > supplier)	Creates a that invokes the given listener with the return of the given supplier.
	toString()
static <T> ActionRunnable<T>	wrap(ActionListener<T> listener, org.elasticsearch.core.CheckedConsumer<> consumer)	Creates a that wraps the given listener and a consumer of it that is executed when the is run.

Methods inherited from class org.elasticsearch.common.util.concurrent.AbstractRunnable

doRun, isForceExecution, onAfter, onRejection, run

Methods inherited from class java.lang.

, , , , , , , , ,

Field Details

listener

protected final ActionListener<Response> listener

Constructor Details

ActionRunnable

public ActionRunnable(ActionListener<Response> listener)

Method Details

run

public static <T> ActionRunnable<T> run(ActionListener<T> listener,
 org.elasticsearch.core.CheckedRunnable<> runnable)

Creates a that invokes the given listener with null after the given runnable has executed.

Parameters:

listener - Listener to invoke

runnable - Runnable to execute

Returns:

Wrapped Runnable

supply

public static <T> ActionRunnable<T> supply(ActionListener<T> listener,
 > supplier)

Creates a that invokes the given listener with the return of the given supplier.

Parameters:

listener - Listener to invoke

supplier - Supplier that provides value to pass to listener

Returns:

Wrapped Runnable

wrap

public static <T> ActionRunnable<T> wrap(ActionListener<T> listener,
 org.elasticsearch.core.CheckedConsumer<> consumer)

Creates a that wraps the given listener and a consumer of it that is executed when the is run. Invokes ActionListener.onFailure(Exception) on it if an exception is thrown on executing the consumer.

Type Parameters:

T - Type of the given ActionListener

Parameters:

listener - ActionListener to wrap

consumer - Consumer of wrapped ActionListener

Returns:

Wrapped Runnable

onFailure

public void onFailure( e)

Calls the action listeners ActionListener.onFailure(Exception) method with the given exception. This method is invoked for all exception thrown by AbstractRunnable.doRun()

Specified by:

onFailure in class AbstractRunnable

toString

public  toString()

Overrides:

in class