at.molindo.esi4j.util

Class ListenableAsyncResult<V>

java.lang.Object

at.molindo.thirdparty.org.springframework.scheduling.annotation.AsyncResult<V>

at.molindo.esi4j.util.ListenableAsyncResult<V>

All Implemented Interfaces:

Future<V>, org.elasticsearch.action.ActionFuture<V>, org.elasticsearch.action.ListenableActionFuture<V>

public class ListenableAsyncResult<V>
extends at.molindo.thirdparty.org.springframework.scheduling.annotation.AsyncResult<V>
implements org.elasticsearch.action.ListenableActionFuture<V>

Constructor Summary

Constructors

Constructor and Description
ListenableAsyncResult(V value, org.elasticsearch.threadpool.ThreadPool threadPool)

Method Summary

Modifier and Type	Method and Description
V	actionGet()
V	actionGet(long timeoutMillis)
V	actionGet(long timeout, TimeUnit unit)
V	actionGet(String timeout)
V	actionGet(org.elasticsearch.common.unit.TimeValue timeout)
void	addListener(org.elasticsearch.action.ActionListener<V> listener)
static <V> ListenableAsyncResult<V>	create(V value)
static <V> ListenableAsyncResult<V>	create(V value, org.elasticsearch.client.Client client, org.elasticsearch.action.ActionRequest<?> request)
Throwable	getRootFailure()

Methods inherited from class at.molindo.thirdparty.org.springframework.scheduling.annotation.AsyncResult

cancel, get, get, isCancelled, isDone

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.Future

cancel, get, get, isCancelled, isDone

Constructor Detail

ListenableAsyncResult

public ListenableAsyncResult(V value,
                             org.elasticsearch.threadpool.ThreadPool threadPool)

Method Detail

create

public static <V> ListenableAsyncResult<V> create(V value)

create

public static <V> ListenableAsyncResult<V> create(V value,
                                                  org.elasticsearch.client.Client client,
                                                  org.elasticsearch.action.ActionRequest<?> request)

actionGet

public V actionGet()
            throws org.elasticsearch.ElasticsearchException

Specified by:

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

Throws:

org.elasticsearch.ElasticsearchException

actionGet

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

Specified by:

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

Throws:

org.elasticsearch.ElasticsearchException

actionGet

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

Specified by:

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

Throws:

org.elasticsearch.ElasticsearchException

actionGet

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

Specified by:

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

Throws:

org.elasticsearch.ElasticsearchException

actionGet

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

Specified by:

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

Throws:

org.elasticsearch.ElasticsearchException

getRootFailure

public Throwable getRootFailure()

Specified by:

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

addListener

public void addListener(org.elasticsearch.action.ActionListener<V> listener)

Specified by:

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