org.elasticsearch.action.support

Class AbstractListenableActionFuture<T,L>

java.lang.Object

org.elasticsearch.common.util.concurrent.BaseFuture<T>

org.elasticsearch.action.support.AdapterActionFuture<T,L>

org.elasticsearch.action.support.AbstractListenableActionFuture<T,L>

All Implemented Interfaces:

java.util.concurrent.Future<T>, ActionFuture<T>, ActionListener<L>, ListenableActionFuture<T>

Direct Known Subclasses:

PlainListenableActionFuture

public abstract class AbstractListenableActionFuture<T,L>
extends AdapterActionFuture<T,L>
implements ListenableActionFuture<T>

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractListenableActionFuture(ThreadPool threadPool)

Method Summary

Modifier and Type	Method and Description
void	addListener(ActionListener<T> listener) Add an action listener to be invoked when a response has received.
protected void	done()
void	internalAddListener(ActionListener<T> listener)
ThreadPool	threadPool()

Methods inherited from class org.elasticsearch.action.support.AdapterActionFuture

actionGet, actionGet, actionGet, actionGet, actionGet, convert, onFailure, onResponse

Methods inherited from class org.elasticsearch.common.util.concurrent.BaseFuture

cancel, 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.ActionFuture

actionGet, actionGet, actionGet, actionGet, actionGet

Methods inherited from interface java.util.concurrent.Future

cancel, get, get, isCancelled, isDone

Methods inherited from interface org.elasticsearch.action.ActionListener

onFailure, onResponse, wrap

Constructor Detail

AbstractListenableActionFuture

protected AbstractListenableActionFuture(ThreadPool threadPool)

Method Detail

threadPool

public ThreadPool threadPool()

addListener

public void addListener(ActionListener<T> listener)

Description copied from interface: ListenableActionFuture

Add an action listener to be invoked when a response has received.

Specified by:

addListener in interface ListenableActionFuture<T>

internalAddListener

public void internalAddListener(ActionListener<T> listener)

done

protected void done()

Overrides:

done in class BaseFuture<T>