Package org.elasticsearch.action.support

Class AdapterActionFuture<T,L>

java.lang.Object

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

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

All Implemented Interfaces:

java.util.concurrent.Future<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 Future.get(), just catching the InterruptedException and throwing an IllegalStateException instead.
T	actionGet(long timeoutMillis)	Similar to Future.get(long, java.util.concurrent.TimeUnit), just catching the InterruptedException and throwing an IllegalStateException instead.
T	actionGet(long timeout, java.util.concurrent.TimeUnit unit)	Similar to Future.get(long, java.util.concurrent.TimeUnit), just catching the InterruptedException and throwing an IllegalStateException instead.
T	actionGet(java.lang.String timeout)	Similar to Future.get(long, java.util.concurrent.TimeUnit), just catching the InterruptedException and throwing an IllegalStateException instead.
T	actionGet(org.elasticsearch.common.unit.TimeValue timeout)	Similar to Future.get(long, java.util.concurrent.TimeUnit), just catching the InterruptedException and throwing an IllegalStateException instead.
protected abstract T	convert(L listenerResponse)
void	onFailure(java.lang.Exception 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.Object

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

Methods inherited from interface org.elasticsearch.action.ActionListener

delegateFailure, delegateResponse, map

Methods inherited from interface java.util.concurrent.Future

cancel, get, get, isCancelled, isDone

Constructor Details

AdapterActionFuture

public AdapterActionFuture()

Method Details

actionGet

public T actionGet()

Description copied from interface: ActionFuture

Similar to Future.get(), just catching the InterruptedException and throwing an IllegalStateException instead. Also catches ExecutionException and throws the actual cause instead.

Specified by:

actionGet in interface ActionFuture<T>

actionGet

public T actionGet(java.lang.String timeout)

Description copied from interface: ActionFuture

Similar to Future.get(long, java.util.concurrent.TimeUnit), just catching the InterruptedException and throwing an IllegalStateException instead. Also catches ExecutionException 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 Future.get(long, java.util.concurrent.TimeUnit), just catching the InterruptedException and throwing an IllegalStateException instead. Also catches ExecutionException and throws the actual cause instead.

Specified by:

actionGet in interface ActionFuture<T>

Parameters:

timeoutMillis - Timeout in millis

actionGet

public T actionGet(org.elasticsearch.common.unit.TimeValue timeout)

Description copied from interface: ActionFuture

Similar to Future.get(long, java.util.concurrent.TimeUnit), just catching the InterruptedException and throwing an IllegalStateException instead. Also catches ExecutionException and throws the actual cause instead.

Specified by:

actionGet in interface ActionFuture<T>

actionGet

public T actionGet(long timeout,
java.util.concurrent.TimeUnit unit)

Description copied from interface: ActionFuture

Similar to Future.get(long, java.util.concurrent.TimeUnit), just catching the InterruptedException and throwing an IllegalStateException instead. Also catches ExecutionException 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(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<T>

convert

protected abstract T convert(L listenerResponse)