Package org.elasticsearch.index.reindex
Interface RejectAwareActionListener<T>
-
- All Superinterfaces:
ActionListener<T>
public interface RejectAwareActionListener<T> extends ActionListener<T>
-
-
Method Summary
Modifier and Type Method Description void
onRejection(java.lang.Exception e)
static <X> RejectAwareActionListener<X>
withResponseHandler(RejectAwareActionListener<?> errorDelegate, java.util.function.Consumer<X> responseHandler)
Return a new listener that delegates failure/reject to errorDelegate but forwards response to responseHandlerstatic <Response> RejectAwareActionListener<Response>
wrap(CheckedConsumer<Response,? extends java.lang.Exception> onResponse, java.util.function.Consumer<java.lang.Exception> onFailure, java.util.function.Consumer<java.lang.Exception> onRejection)
Similar toActionListener.wrap(CheckedConsumer, Consumer)
, extended to have handler for onRejection.-
Methods inherited from interface org.elasticsearch.action.ActionListener
onFailure, onResponse
-
-
-
-
Method Detail
-
onRejection
void onRejection(java.lang.Exception e)
-
withResponseHandler
static <X> RejectAwareActionListener<X> withResponseHandler(RejectAwareActionListener<?> errorDelegate, java.util.function.Consumer<X> responseHandler)
Return a new listener that delegates failure/reject to errorDelegate but forwards response to responseHandler
-
wrap
static <Response> RejectAwareActionListener<Response> wrap(CheckedConsumer<Response,? extends java.lang.Exception> onResponse, java.util.function.Consumer<java.lang.Exception> onFailure, java.util.function.Consumer<java.lang.Exception> onRejection)
Similar toActionListener.wrap(CheckedConsumer, Consumer)
, extended to have handler for onRejection.
-
-