Module org.elasticsearch.server

Package org.elasticsearch.index.reindex

Interface RejectAwareActionListener<T>

All Superinterfaces:

ActionListener<T>

All Known Implementing Classes:

RetryListener

public interface RejectAwareActionListener<T>
extends ActionListener<T>

Method Summary

Modifier and Type	Method	Description
void	onRejection(Exception e)
static <X> RejectAwareActionListener<X>	withResponseHandler(RejectAwareActionListener<?> errorDelegate, 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 Exception> onResponse, Consumer<Exception> onFailure, Consumer<Exception> onRejection)	Similar to ActionListener.wrap(CheckedConsumer, Consumer), extended to have handler for onRejection.

Methods inherited from interface org.elasticsearch.action.ActionListener

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

Method Details

onRejection

void onRejection(Exception e)

withResponseHandler

static <X> RejectAwareActionListener<X> withResponseHandler(RejectAwareActionListener<?> errorDelegate,
 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 Exception> onResponse,
 Consumer<Exception> onFailure,
 Consumer<Exception> onRejection)

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