Package org.elasticsearch.action.bulk

Class Retry

java.lang.Object

org.elasticsearch.action.bulk.Retry

public class Retry
extends Object

Encapsulates synchronous and asynchronous retry logic.

Constructor Summary

Constructors

Constructor	Description
Retry(BackoffPolicy backoffPolicy, Scheduler scheduler)

Method Summary

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

Methods inherited from class java.lang.Object

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