java.lang.Object

org.elasticsearch.action.support.ThreadedActionListener<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, java.lang.String executor, ActionListener<Response> listener, boolean forceExecution)`

Method Summary

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

toString

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

delegateFailure, delegateResponse, map

Constructor Details
- ThreadedActionListener
  
  public ThreadedActionListener(org.apache.logging.log4j.Logger logger, ThreadPool threadPool, java.lang.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(java.lang.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>