org.elasticsearch.action.bulk

Class Retry

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 and Description
static Retry	on(java.lang.Class<? extends java.lang.Throwable> retryOnThrowable)
Retry	policy(BackoffPolicy backoffPolicy)
void	withAsyncBackoff(Client client, BulkRequest bulkRequest, ActionListener<BulkResponse> listener) Invokes #bulk(BulkRequest, ActionListener) on the provided client.
BulkResponse	withSyncBackoff(Client client, BulkRequest bulkRequest) Invokes #bulk(BulkRequest) on the provided client.

Methods inherited from class java.lang.Object

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

Method Detail

on

public static Retry on(java.lang.Class<? extends java.lang.Throwable> retryOnThrowable)

policy

public Retry policy(BackoffPolicy backoffPolicy)

Parameters:

backoffPolicy - The backoff policy that defines how long and how often to wait for retries.

withAsyncBackoff

public void withAsyncBackoff(Client client,
                             BulkRequest bulkRequest,
                             ActionListener<BulkResponse> listener)

Invokes #bulk(BulkRequest, ActionListener) on the provided client. Backs off on the provided exception and delegates results to the provided listener.

Parameters:

client - Client invoking the bulk request.

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

withSyncBackoff

public BulkResponse withSyncBackoff(Client client,
                                    BulkRequest bulkRequest)
                             throws java.lang.Exception

Invokes #bulk(BulkRequest) on the provided client. Backs off on the provided exception.

Parameters:

client - Client invoking the bulk request.

bulkRequest - The bulk request that should be executed.

Returns:

the bulk response as returned by the client.

Throws:

java.lang.Exception - Any exception thrown by the callable.