Module org.elasticsearch.server

Package org.elasticsearch.action

Class LatchedActionListener<T>

java.lang.Object

org.elasticsearch.action.LatchedActionListener<T>

All Implemented Interfaces:

ActionListener<T>

public class LatchedActionListener<T>
extends Object
implements ActionListener<T>

An action listener that allows passing in a CountDownLatch that will be counted down after onResponse or onFailure is called

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.action.ActionListener

ActionListener.Delegating<Response,DelegateResponse>, ActionListener.DelegatingActionListener<T>, ActionListener.DelegatingFailureActionListener<T,R>, ActionListener.MappedActionListener<Response,MappedResponse>, ActionListener.RunAfterActionListener<T>, ActionListener.RunBeforeActionListener<T>

Field Summary

Fields inherited from interface org.elasticsearch.action.ActionListener

NOOP

Constructor Summary

Constructors

Constructor	Description
LatchedActionListener(ActionListener<T> delegate, CountDownLatch latch)

Method Summary

Modifier and Type	Method	Description
void	onFailure(Exception e)	A failure caused by an exception at some phase of the task.
void	onResponse(T t)	Handle action response.

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.ActionListener

delegateFailure, delegateResponse, map

Constructor Details

LatchedActionListener

public LatchedActionListener(ActionListener<T> delegate,
 CountDownLatch latch)

Method Details

onResponse

public void onResponse(T t)

Description copied from interface: ActionListener

Handle action response. This response may constitute a failure or a success but it is up to the listener to make that decision.

Specified by:

onResponse in interface ActionListener<T>

onFailure

public void onFailure(Exception e)

Description copied from interface: ActionListener

A failure caused by an exception at some phase of the task.

Specified by:

onFailure in interface ActionListener<T>