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.MappedActionListener<Response,MappedResponse>
-
Constructor Summary
Constructors Constructor Description AdapterActionFuture()
-
Method Summary
Modifier and Type Method Description T
actionGet()
Similar toFuture.get()
, just catching theInterruptedException
and throwing anIllegalStateException
instead.T
actionGet(long timeoutMillis)
Similar toFuture.get(long, java.util.concurrent.TimeUnit)
, just catching theInterruptedException
and throwing anIllegalStateException
instead.T
actionGet(long timeout, java.util.concurrent.TimeUnit unit)
Similar toFuture.get(long, java.util.concurrent.TimeUnit)
, just catching theInterruptedException
and throwing anIllegalStateException
instead.T
actionGet(java.lang.String timeout)
Similar toFuture.get(long, java.util.concurrent.TimeUnit)
, just catching theInterruptedException
and throwing anIllegalStateException
instead.T
actionGet(org.elasticsearch.common.unit.TimeValue timeout)
Similar toFuture.get(long, java.util.concurrent.TimeUnit)
, just catching theInterruptedException
and throwing anIllegalStateException
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
map
Methods inherited from interface java.util.concurrent.Future
cancel, get, get, isCancelled, isDone
-
Constructor Details
-
AdapterActionFuture
public AdapterActionFuture()
-
-
Method Details
-
actionGet
Description copied from interface:ActionFuture
Similar toFuture.get()
, just catching theInterruptedException
and throwing anIllegalStateException
instead. Also catchesExecutionException
and throws the actual cause instead.- Specified by:
actionGet
in interfaceActionFuture<T>
-
actionGet
Description copied from interface:ActionFuture
Similar toFuture.get(long, java.util.concurrent.TimeUnit)
, just catching theInterruptedException
and throwing anIllegalStateException
instead. Also catchesExecutionException
and throws the actual cause instead.- Specified by:
actionGet
in interfaceActionFuture<T>
-
actionGet
Description copied from interface:ActionFuture
Similar toFuture.get(long, java.util.concurrent.TimeUnit)
, just catching theInterruptedException
and throwing anIllegalStateException
instead. Also catchesExecutionException
and throws the actual cause instead.- Specified by:
actionGet
in interfaceActionFuture<T>
- Parameters:
timeoutMillis
- Timeout in millis
-
actionGet
Description copied from interface:ActionFuture
Similar toFuture.get(long, java.util.concurrent.TimeUnit)
, just catching theInterruptedException
and throwing anIllegalStateException
instead. Also catchesExecutionException
and throws the actual cause instead.- Specified by:
actionGet
in interfaceActionFuture<T>
-
actionGet
Description copied from interface:ActionFuture
Similar toFuture.get(long, java.util.concurrent.TimeUnit)
, just catching theInterruptedException
and throwing anIllegalStateException
instead. Also catchesExecutionException
and throws the actual cause instead.- Specified by:
actionGet
in interfaceActionFuture<T>
-
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<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 interfaceActionListener<T>
-
convert
-