Package org.elasticsearch.action.support

Class GroupedActionListener<T>

java.lang.Object

org.elasticsearch.action.support.GroupedActionListener<T>

All Implemented Interfaces:

ActionListener<T>

public final class GroupedActionListener<T>
extends java.lang.Object
implements ActionListener<T>

An action listener that delegates it's results to another listener once it has received one or more failures or N results. This allows synchronous tasks to be forked off in a loop with the same listener and respond to a higher level listener once all tasks responded.

Constructor Summary

Constructors

Constructor	Description
GroupedActionListener(ActionListener<java.util.Collection<T>> delegate, int groupSize, java.util.Collection<T> defaults)	Creates a new listener

Method Summary

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

Methods inherited from interface org.elasticsearch.action.ActionListener

onFailure, onResponse, toBiConsumer, wrap, wrap

Methods inherited from class java.lang.Object

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

Constructor Detail

GroupedActionListener

public GroupedActionListener(ActionListener<java.util.Collection<T>> delegate,
                             int groupSize,
                             java.util.Collection<T> defaults)

Creates a new listener

Parameters:

delegate - the delegate listener

groupSize - the group size

Method Detail

onResponse

public void onResponse(T element)

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