Module org.elasticsearch.server
Package org.elasticsearch.action.support
Class AbstractThreadedActionListener<Response>
java.lang.Object
org.elasticsearch.action.support.AbstractThreadedActionListener<Response>
- All Implemented Interfaces:
ActionListener<Response>
- Direct Known Subclasses:
RefCountAwareThreadedActionListener,ThreadedActionListener
public abstract class AbstractThreadedActionListener<Response>
extends Object
implements ActionListener<Response>
Base class for action listeners that wrap another action listener and dispatch its completion to an executor.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final ActionListener<Response> protected final Executorprotected final boolean -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedAbstractThreadedActionListener(Executor executor, boolean forceExecution, ActionListener<Response> delegate) -
Method Summary
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.elasticsearch.action.ActionListener
delegateFailure, delegateFailureAndWrap, delegateFailureIgnoreResponseAndWrap, delegateResponse, map, onResponse, safeMap
-
Field Details
-
executor
-
delegate
-
forceExecution
protected final boolean forceExecution
-
-
Constructor Details
-
AbstractThreadedActionListener
protected AbstractThreadedActionListener(Executor executor, boolean forceExecution, ActionListener<Response> delegate)
-
-
Method Details
-
onFailure
Description copied from interface:ActionListenerComplete this listener with an exceptional response.- Specified by:
onFailurein interfaceActionListener<Response>
-
toString
-