Class Retry

java.lang.Object
org.elasticsearch.action.bulk.Retry

public class Retry extends Object
Encapsulates synchronous and asynchronous retry logic.
  • Constructor Details

  • Method Details

    • withBackoff

      public void withBackoff(BiConsumer<BulkRequest,​ActionListener<BulkResponse>> consumer, BulkRequest bulkRequest, ActionListener<BulkResponse> listener)
      Invokes #accept(BulkRequest, ActionListener). Backs off on the provided exception and delegates results to the provided listener. Retries will be scheduled using the class's thread pool.
      Parameters:
      consumer - The consumer to which apply the request and listener
      bulkRequest - The bulk request that should be executed.
      listener - A listener that is invoked when the bulk request finishes or completes with an exception. The listener is not
    • withBackoff

      public PlainActionFuture<BulkResponse> withBackoff(BiConsumer<BulkRequest,​ActionListener<BulkResponse>> consumer, BulkRequest bulkRequest)
      Invokes #accept(BulkRequest, ActionListener). Backs off on the provided exception. Retries will be scheduled using the class's thread pool.
      Parameters:
      consumer - The consumer to which apply the request and listener
      bulkRequest - The bulk request that should be executed.
      Returns:
      a future representing the bulk response returned by the client.