org.elasticsearch.action

Interface ActionListener<Response>

All Known Implementing Classes:

AbstractListenableActionFuture, AcknowledgedRestListener, AdapterActionFuture, ContextPreservingActionListener, DelegatingActionListener, GroupedActionListener, LatchedActionListener, NotifyOnceListener, PlainActionFuture, PlainListenableActionFuture, RestActionListener, RestActions.NodesResponseRestListener, RestBuilderListener, RestResponseListener, RestStatusToXContentListener, RestToXContentListener, ThreadedActionListener

public interface ActionListener<Response>

A listener for action responses or failures.

Method Summary

Modifier and Type	Method and Description
void	onFailure(java.lang.Exception e) A failure caused by an exception at some phase of the task.
static <Response> void	onFailure(java.lang.Iterable<ActionListener<Response>> listeners, java.lang.Exception failure) Notifies every given listener with the failure passed to onFailure(Exception).
static <Response> void	onResponse(java.lang.Iterable<ActionListener<Response>> listeners, Response response) Notifies every given listener with the response passed to onResponse(Object).
void	onResponse(Response response) Handle action response.
static <Response> ActionListener<Response>	wrap(CheckedConsumer<Response,? extends java.lang.Exception> onResponse, java.util.function.Consumer<java.lang.Exception> onFailure) Creates a listener that listens for a response (or failure) and executes the corresponding consumer when the response (or failure) is received.

Method Detail

onResponse

void onResponse(Response response)

Handle action response. This response may constitute a failure or a success but it is up to the listener to make that decision.

onFailure

void onFailure(java.lang.Exception e)

A failure caused by an exception at some phase of the task.

wrap

static <Response> ActionListener<Response> wrap(CheckedConsumer<Response,? extends java.lang.Exception> onResponse,
                                                java.util.function.Consumer<java.lang.Exception> onFailure)

Creates a listener that listens for a response (or failure) and executes the corresponding consumer when the response (or failure) is received.

Type Parameters:

Response - the type of the response

Parameters:

onResponse - the consumer of the response, when the listener receives one

onFailure - the consumer of the failure, when the listener receives one

Returns:

a listener that listens for responses and invokes the consumer when received

onResponse

static <Response> void onResponse(java.lang.Iterable<ActionListener<Response>> listeners,
                                  Response response)

Notifies every given listener with the response passed to onResponse(Object). If a listener itself throws an exception the exception is forwarded to onFailure(Exception). If in turn onFailure(Exception) fails all remaining listeners will be processed and the caught exception will be re-thrown.

onFailure

static <Response> void onFailure(java.lang.Iterable<ActionListener<Response>> listeners,
                                 java.lang.Exception failure)

Notifies every given listener with the failure passed to onFailure(Exception). If a listener itself throws an exception all remaining listeners will be processed and the caught exception will be re-thrown.