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(org.elasticsearch.common.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.
-
Method Details
-
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(org.elasticsearch.common.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.
-