public abstract class AdapterActionFuture<T,L> extends BaseFuture<T> implements ActionFuture<T>, ActionListener<L>
| Constructor and Description |
|---|
AdapterActionFuture() |
cancel, done, get, get, interruptTask, isCancelled, isDone, set, setExceptionpublic T actionGet() throws ElasticsearchException
ActionFutureFuture.get(), just catching the InterruptedException and throwing
an ElasticsearchIllegalStateException instead. Also catches
ExecutionException and throws the actual cause instead.
Note, the actual cause is unwrapped to the actual failure (for example, unwrapped
from RemoteTransportException. The root failure is
still accessible using ActionFuture.getRootFailure().
actionGet in interface ActionFuture<T>ElasticsearchExceptionpublic T actionGet(String timeout) throws ElasticsearchException
ActionFutureFuture.get(long, java.util.concurrent.TimeUnit), just catching the InterruptedException and throwing
an ElasticsearchIllegalStateException instead. Also catches
ExecutionException and throws the actual cause instead.
Note, the actual cause is unwrapped to the actual failure (for example, unwrapped
from RemoteTransportException. The root failure is
still accessible using ActionFuture.getRootFailure().
actionGet in interface ActionFuture<T>ElasticsearchExceptionpublic T actionGet(long timeoutMillis) throws ElasticsearchException
ActionFutureFuture.get(long, java.util.concurrent.TimeUnit), just catching the InterruptedException and throwing
an ElasticsearchIllegalStateException instead. Also catches
ExecutionException and throws the actual cause instead.
Note, the actual cause is unwrapped to the actual failure (for example, unwrapped
from RemoteTransportException. The root failure is
still accessible using ActionFuture.getRootFailure().
actionGet in interface ActionFuture<T>timeoutMillis - Timeout in millisElasticsearchExceptionpublic T actionGet(TimeValue timeout) throws ElasticsearchException
ActionFutureFuture.get(long, java.util.concurrent.TimeUnit), just catching the InterruptedException and throwing
an ElasticsearchIllegalStateException instead. Also catches
ExecutionException and throws the actual cause instead.
Note, the actual cause is unwrapped to the actual failure (for example, unwrapped
from RemoteTransportException. The root failure is
still accessible using ActionFuture.getRootFailure().
actionGet in interface ActionFuture<T>ElasticsearchExceptionpublic T actionGet(long timeout, TimeUnit unit) throws ElasticsearchException
ActionFutureFuture.get(long, java.util.concurrent.TimeUnit), just catching the InterruptedException and throwing
an ElasticsearchIllegalStateException instead. Also catches
ExecutionException and throws the actual cause instead.
Note, the actual cause is unwrapped to the actual failure (for example, unwrapped
from RemoteTransportException. The root failure is
still accessible using ActionFuture.getRootFailure().
actionGet in interface ActionFuture<T>ElasticsearchExceptionpublic void onResponse(L result)
ActionListeneronResponse in interface ActionListener<L>public void onFailure(Throwable e)
ActionListeneronFailure in interface ActionListener<L>public Throwable getRootFailure()
ActionFuturegetRootFailure in interface ActionFuture<T>Copyright © 2009–2016. All rights reserved.