Package org.elasticsearch.action.support

Class AdapterActionFuture<T,L>

org.elasticsearch.common.util.concurrent.BaseFuture<T>

org.elasticsearch.action.support.AdapterActionFuture<T,L>

All Implemented Interfaces:

<T>, ActionFuture<T>, ActionListener<L>

Direct Known Subclasses:

ListenableActionFuture, PlainActionFuture

public abstract class AdapterActionFuture<T,L>
extends BaseFuture<T>
implements ActionFuture<T>, ActionListener<L>

Nested Class Summary

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>

Constructor Summary

Constructors

Constructor	Description
AdapterActionFuture()

Method Summary

Modifier and Type	Method	Description
T	actionGet()	Similar to , just catching the and throwing an instead.
T	actionGet(long timeoutMillis)	Similar to , just catching the and throwing an instead.
T	actionGet(long timeout, unit)	Similar to , just catching the and throwing an instead.
T	timeout)	Similar to , just catching the and throwing an instead.
T	actionGet(org.elasticsearch.core.TimeValue timeout)	Similar to , just catching the and throwing an instead.
protected abstract T	convert(L listenerResponse)
void	e)	A failure caused by an exception at some phase of the task.
void	onResponse(L result)	Handle action response.

Methods inherited from class org.elasticsearch.common.util.concurrent.BaseFuture

blockingAllowed, cancel, done, get, get, interruptTask, isCancelled, isDone, set, setException

Methods inherited from class java.lang.

, , , , , , , , , ,

Methods inherited from interface org.elasticsearch.action.ActionListener

delegateFailure, delegateResponse, map

Methods inherited from interface java.util.concurrent.

, , , ,

Constructor Details

AdapterActionFuture

public AdapterActionFuture()

Method Details

actionGet

public T actionGet()

Description copied from interface: ActionFuture

Similar to , just catching the and throwing an instead. Also catches and throws the actual cause instead.

Specified by:

actionGet in interface ActionFuture<T>

actionGet

public  timeout)

Description copied from interface: ActionFuture

Similar to , just catching the and throwing an instead. Also catches and throws the actual cause instead.

Specified by:

actionGet in interface ActionFuture<T>

actionGet

public T actionGet(long timeoutMillis)

Description copied from interface: ActionFuture

Similar to , just catching the and throwing an instead. Also catches and throws the actual cause instead.

Specified by:

actionGet in interface ActionFuture<T>

Parameters:

timeoutMillis - Timeout in millis

actionGet

public T actionGet(org.elasticsearch.core.TimeValue timeout)

Description copied from interface: ActionFuture

Similar to , just catching the and throwing an instead. Also catches and throws the actual cause instead.

Specified by:

actionGet in interface ActionFuture<T>

actionGet

public T actionGet(long timeout,
  unit)

Description copied from interface: ActionFuture

Similar to , just catching the and throwing an instead. Also catches and throws the actual cause instead.

Specified by:

actionGet in interface ActionFuture<T>

onResponse

public void onResponse(L result)

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<T>

onFailure

public void onFailure( e)

Description copied from interface: ActionListener

A failure caused by an exception at some phase of the task.

Specified by:

onFailure in interface ActionListener<T>

convert

protected abstract T convert(L listenerResponse)