java.lang.Object

org.elasticsearch.action.bulk.Retry

public class Retry
extends java.lang.Object

Encapsulates synchronous and asynchronous retry logic.

Method Summary

Modifier and Type	Method	Description
`PlainActionFuture<BulkResponse>`	`withBackoff(java.util.function.BiConsumer<BulkRequest,ActionListener<BulkResponse>> consumer, BulkRequest bulkRequest)`	Invokes #accept(BulkRequest, ActionListener).
`void`	`withBackoff(java.util.function.BiConsumer<BulkRequest,ActionListener<BulkResponse>> consumer, BulkRequest bulkRequest, ActionListener<BulkResponse> listener)`	Invokes #accept(BulkRequest, ActionListener).

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

Constructor Details
- Retry
  
  public Retry(BackoffPolicy backoffPolicy, Scheduler scheduler)
Method Details
- withBackoff
  
  public void withBackoff(java.util.function.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(java.util.function.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.

Class Retry