Package org.elasticsearch.action.support
Class ThreadedActionListener<Response>
java.lang.Object
org.elasticsearch.action.support.ThreadedActionListener<Response>
- All Implemented Interfaces:
ActionListener<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.Nested classes/interfaces inherited from interface org.elasticsearch.action.ActionListener
ActionListener.MappedActionListener<Response,MappedResponse>
-
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.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.elasticsearch.action.ActionListener
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
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 interfaceActionListener<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 interfaceActionListener<Response>
-