java.lang.Object

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

public final class ThreadedActionListener<Response>
extends java.lang.Object
implements ActionListener<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.

Constructor Summary

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

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.

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

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.
  
  Specified by:
  
  onResponse in interface ActionListener<Response>
- 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>