Package org.elasticsearch.action.support

Class 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

      All Methods Instance Methods Concrete Methods 
      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 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>