Package org.elasticsearch.action.support

Class ThreadedActionListener<Response>

java.lang.Object

org.elasticsearch.action.ActionListener.Delegating<Response,Response>

org.elasticsearch.action.support.ThreadedActionListener<Response>

All Implemented Interfaces:

ActionListener<Response>

public final class ThreadedActionListener<Response>
extends ActionListener.Delegating<Response,Response>

An action listener that wraps another action listener and threading its execution.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ThreadedActionListener.Wrapper	Wrapper that can be used to automatically wrap a listener in a threaded listener if needed.

Nested classes/interfaces inherited from interface org.elasticsearch.action.ActionListener

ActionListener.Delegating<Response,DelegateResponse>, ActionListener.DelegatingActionListener<T>, ActionListener.DelegatingFailureActionListener<T,R>, ActionListener.MappedActionListener<Response,MappedResponse>, ActionListener.RunAfterActionListener<T>, ActionListener.RunBeforeActionListener<T>

Field Summary

Fields inherited from class org.elasticsearch.action.ActionListener.Delegating

delegate

Constructor Summary

Constructors

Constructor	Description
ThreadedActionListener(org.apache.logging.log4j.Logger logger, ThreadPool threadPool, String executor, ActionListener<Response> listener, boolean forceExecution)

Method Summary

Modifier and Type	Method	Description
void	onFailure(Exception e)	A failure caused by an exception at some phase of the task.
void	onResponse(Response response)	Handle action response.

Methods inherited from class org.elasticsearch.action.ActionListener.Delegating

toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.elasticsearch.action.ActionListener

delegateFailure, delegateResponse, map

Constructor Details

ThreadedActionListener

public ThreadedActionListener(org.apache.logging.log4j.Logger logger,
 ThreadPool threadPool,
 String executor,
 ActionListener<Response> listener,
 boolean forceExecution)

Method Details

onResponse

public void onResponse(Response response)

Description copied from interface: ActionListener

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

onFailure

public void onFailure(Exception e)

Description copied from interface: ActionListener

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

Specified by:

onFailure in interface ActionListener<Response>

Overrides:

onFailure in class ActionListener.Delegating<Response,Response>