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 responseHandler
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 to ActionListener.wrap(CheckedConsumer, Consumer), extended to have handler for onRejection.

Methods inherited from interface org.elasticsearch.action.ActionListener

onFailure, onResponse

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(CheckedConsumer<Response,? extends java.lang.Exception> onResponse, java.util.function.Consumer<java.lang.Exception> onFailure, java.util.function.Consumer<java.lang.Exception> onRejection)

Similar to ActionListener.wrap(CheckedConsumer, Consumer), extended to have handler for onRejection.