org.graylog2.indexer.elasticsearch

Class GlobalTimeoutClient.GlobalTimeoutActionFuture<T>

java.lang.Object

org.graylog2.indexer.elasticsearch.GlobalTimeoutClient.GlobalTimeoutActionFuture<T>

All Implemented Interfaces:

Future<T>, org.elasticsearch.action.ActionFuture<T>

Enclosing class:

GlobalTimeoutClient

public static class GlobalTimeoutClient.GlobalTimeoutActionFuture<T>
extends Object
implements org.elasticsearch.action.ActionFuture<T>

Method Summary

Methods

Modifier and Type	Method and Description
T	actionGet()
T	actionGet(long timeoutMillis)
T	actionGet(long timeout, TimeUnit unit)
T	actionGet(String timeout)
T	actionGet(org.elasticsearch.common.unit.TimeValue timeout)
boolean	cancel(boolean mayInterruptIfRunning)
static <Response extends org.elasticsearch.action.ActionResponse> GlobalTimeoutClient.GlobalTimeoutActionFuture<Response>	create(org.elasticsearch.action.ActionFuture<Response> actionFuture, long timeout, TimeUnit unit)
T	get()
T	get(long timeout, TimeUnit unit)
Throwable	getRootFailure()
boolean	isCancelled()
boolean	isDone()

Methods inherited from class java.lang.Object

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

Method Detail

create

public static <Response extends org.elasticsearch.action.ActionResponse> GlobalTimeoutClient.GlobalTimeoutActionFuture<Response> create(org.elasticsearch.action.ActionFuture<Response> actionFuture,
                                                                                                                        long timeout,
                                                                                                                        TimeUnit unit)

actionGet

public T actionGet()
            throws org.elasticsearch.ElasticsearchException

Specified by:

actionGet in interface org.elasticsearch.action.ActionFuture<T>

Throws:

org.elasticsearch.ElasticsearchException

actionGet

public T actionGet(String timeout)
            throws org.elasticsearch.ElasticsearchException

Specified by:

actionGet in interface org.elasticsearch.action.ActionFuture<T>

Throws:

org.elasticsearch.ElasticsearchException

actionGet

public T actionGet(long timeoutMillis)
            throws org.elasticsearch.ElasticsearchException

Specified by:

actionGet in interface org.elasticsearch.action.ActionFuture<T>

Throws:

org.elasticsearch.ElasticsearchException

actionGet

public T actionGet(long timeout,
          TimeUnit unit)
            throws org.elasticsearch.ElasticsearchException

Specified by:

actionGet in interface org.elasticsearch.action.ActionFuture<T>

Throws:

org.elasticsearch.ElasticsearchException

actionGet

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

Specified by:

actionGet in interface org.elasticsearch.action.ActionFuture<T>

Throws:

org.elasticsearch.ElasticsearchException

getRootFailure

public Throwable getRootFailure()

Specified by:

getRootFailure in interface org.elasticsearch.action.ActionFuture<T>

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<T>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<T>

isDone

public boolean isDone()

Specified by:

isDone in interface Future<T>

get

public T get()
      throws InterruptedException,
             ExecutionException

Specified by:

get in interface Future<T>

Throws:

InterruptedException

ExecutionException

get

public T get(long timeout,
    TimeUnit unit)
      throws InterruptedException,
             ExecutionException,
             TimeoutException

Specified by:

get in interface Future<T>

Throws:

InterruptedException

ExecutionException

TimeoutException