Module org.elasticsearch.server

Package org.elasticsearch.index.reindex

Class RetryListener<T>

java.lang.Object

org.elasticsearch.action.DelegatingActionListener<T,T>

org.elasticsearch.index.reindex.RetryListener<T>

All Implemented Interfaces:

ActionListener<T>, RejectAwareActionListener<T>

public class RetryListener<T>
extends DelegatingActionListener<T,T>
implements RejectAwareActionListener<T>

Field Summary

Fields inherited from class org.elasticsearch.action.DelegatingActionListener

delegate

Constructor Summary

Constructors

Constructor	Description
RetryListener(org.apache.logging.log4j.Logger logger, ThreadPool threadPool, BackoffPolicy backoffPolicy, Consumer<RejectAwareActionListener<T>> retryHandler, ActionListener<T> delegate)

Method Summary

Modifier and Type	Method	Description
void	onRejection(Exception e)
void	onResponse(T response)	Complete this listener with a successful (or at least, non-exceptional) response.

Methods inherited from class org.elasticsearch.action.DelegatingActionListener

onFailure, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.action.ActionListener

delegateFailure, delegateFailureAndWrap, delegateFailureIgnoreResponseAndWrap, delegateResponse, map, onFailure, safeMap

Constructor Details

RetryListener

public RetryListener(org.apache.logging.log4j.Logger logger,
 ThreadPool threadPool,
 BackoffPolicy backoffPolicy,
 Consumer<RejectAwareActionListener<T>> retryHandler,
 ActionListener<T> delegate)

Method Details

onResponse

public void onResponse(T response)

Description copied from interface: ActionListener

Complete this listener with a successful (or at least, non-exceptional) response.

Specified by:

onResponse in interface ActionListener<T>

onRejection

public void onRejection(Exception e)

Specified by:

onRejection in interface RejectAwareActionListener<T>