Package org.elasticsearch.index.reindex

Interface RejectAwareActionListener<T>

All Superinterfaces:

ActionListener<T>

public interface RejectAwareActionListener<T>
extends ActionListener<T>

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.action.ActionListener

ActionListener.Delegating<Response,DelegateResponse>, ActionListener.DelegatingActionListener<T>, ActionListener.DelegatingFailureActionListener<T,R>, ActionListener.MappedActionListener<Response,MappedResponse>, ActionListener.RunAfterActionListener<T>, ActionListener.RunBeforeActionListener<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, delegateResponse, map, onFailure, onResponse

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.