org.elasticsearch.groovy.client.action
Class GActionFuture<T>

java.lang.Object
  org.elasticsearch.groovy.client.action.GActionFuture<T>

All Implemented Interfaces:

java.util.concurrent.Future<T>, org.elasticsearch.action.ActionFuture<T>, org.elasticsearch.action.ActionListener<T>, org.elasticsearch.action.ListenableActionFuture<T>

public class GActionFuture<T>
extends java.lang.Object
implements org.elasticsearch.action.ListenableActionFuture<T>, org.elasticsearch.action.ActionListener<T>

Constructor Summary

GActionFuture(org.elasticsearch.action.ListenableActionFuture<T> future)

GActionFuture(org.elasticsearch.threadpool.ThreadPool threadPool, org.elasticsearch.action.ActionRequest request)

Method Summary

T	actionGet()
T	actionGet(long timeoutMillis)
T	actionGet(long timeout, java.util.concurrent.TimeUnit unit)
T	actionGet(java.lang.String timeout)
T	actionGet(org.elasticsearch.common.unit.TimeValue timeout)
void	addListener(org.elasticsearch.action.ActionListener<T> tActionListener)
void	addListener(java.lang.Runnable listener)
boolean	cancel(boolean mayInterruptIfRunning)
T	get()
T	get(long timeout, java.util.concurrent.TimeUnit unit)
T	getResponse()
boolean	isCancelled()
boolean	isDone()
void	onFailure(java.lang.Throwable e)
void	onResponse(T t)
T	response(long timeoutMillis)
T	response(long timeout, java.util.concurrent.TimeUnit unit)
T	response(java.lang.String timeout)
T	response(org.elasticsearch.common.unit.TimeValue timeout)
void	setFailure(groovy.lang.Closure failure)
void	setListener(groovy.lang.Closure listener)
void	setSuccess(groovy.lang.Closure success)

Methods inherited from class java.lang.Object

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

Constructor Detail

GActionFuture

public GActionFuture(org.elasticsearch.action.ListenableActionFuture<T> future)

GActionFuture

public GActionFuture(org.elasticsearch.threadpool.ThreadPool threadPool,
                     org.elasticsearch.action.ActionRequest request)

Method Detail

setListener

public void setListener(groovy.lang.Closure listener)

setSuccess

public void setSuccess(groovy.lang.Closure success)

setFailure

public void setFailure(groovy.lang.Closure failure)

getResponse

public T getResponse()

response

public T response(java.lang.String timeout)
           throws org.elasticsearch.ElasticSearchException

Throws:

org.elasticsearch.ElasticSearchException

response

public T response(long timeoutMillis)
           throws org.elasticsearch.ElasticSearchException

Throws:

org.elasticsearch.ElasticSearchException

response

public T response(org.elasticsearch.common.unit.TimeValue timeout)
           throws org.elasticsearch.ElasticSearchException

Throws:

org.elasticsearch.ElasticSearchException

response

public T response(long timeout,
                  java.util.concurrent.TimeUnit unit)
           throws org.elasticsearch.ElasticSearchException

Throws:

org.elasticsearch.ElasticSearchException

onResponse

public void onResponse(T t)

Specified by:

onResponse in interface org.elasticsearch.action.ActionListener<T>

onFailure

public void onFailure(java.lang.Throwable e)

Specified by:

onFailure in interface org.elasticsearch.action.ActionListener<T>

addListener

public void addListener(org.elasticsearch.action.ActionListener<T> tActionListener)

Specified by:

addListener in interface org.elasticsearch.action.ListenableActionFuture<T>

addListener

public void addListener(java.lang.Runnable listener)

Specified by:

addListener in interface org.elasticsearch.action.ListenableActionFuture<T>

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(java.lang.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,
                   java.util.concurrent.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

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface java.util.concurrent.Future<T>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface java.util.concurrent.Future<T>

isDone

public boolean isDone()

Specified by:

isDone in interface java.util.concurrent.Future<T>

get

public T get()
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException

Specified by:

get in interface java.util.concurrent.Future<T>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

get

public T get(long timeout,
             java.util.concurrent.TimeUnit unit)
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException,
             java.util.concurrent.TimeoutException

Specified by:

get in interface java.util.concurrent.Future<T>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException