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

Fields

Modifier and Type	Field	Description
protected final ActionListener<Response>	delegate
protected final Executor	executor
protected final boolean	forceExecution

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractThreadedActionListener(Executor executor, boolean forceExecution, ActionListener<Response> delegate)

Method Summary

Modifier and Type	Method	Description
final void	onFailure(Exception e)	A failure caused by an exception at some phase of the task.
final String	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, delegateFailureAndWrap, delegateResponse, map, onResponse, safeMap

Field Details

executor

protected final Executor executor

delegate

protected final ActionListener<Response> delegate

forceExecution

protected final boolean forceExecution

Constructor Details

AbstractThreadedActionListener

protected AbstractThreadedActionListener(Executor executor,
 boolean forceExecution,
 ActionListener<Response> delegate)

Method Details

onFailure

public final 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>

toString

public final String toString()

Overrides:

toString in class Object