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
ConstructorsConstructorDescriptionRetryListener(org.apache.logging.log4j.Logger logger, ThreadPool threadPool, BackoffPolicy backoffPolicy, Consumer<RejectAwareActionListener<T>> retryHandler, ActionListener<T> delegate) -
Method Summary
Modifier and TypeMethodDescriptionvoidvoidonResponse(T response) Complete this listener with a successful (or at least, non-exceptional) response.Methods inherited from class org.elasticsearch.action.DelegatingActionListener
onFailure, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods 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
Description copied from interface:ActionListenerComplete this listener with a successful (or at least, non-exceptional) response.- Specified by:
onResponsein interfaceActionListener<T>
-
onRejection
- Specified by:
onRejectionin interfaceRejectAwareActionListener<T>
-