org.elasticsearch.action.support

Class ContextPreservingActionListener<R>

java.lang.Object

org.elasticsearch.action.support.ContextPreservingActionListener<R>

All Implemented Interfaces:

ActionListener<R>

public final class ContextPreservingActionListener<R>
extends java.lang.Object
implements ActionListener<R>

Restores the given ThreadContext.StoredContext once the listener is invoked

Constructor Summary

Constructors

Constructor and Description
ContextPreservingActionListener(java.util.function.Supplier<ThreadContext.StoredContext> contextSupplier, ActionListener<R> delegate)

Method Summary

Modifier and Type	Method and Description
void	onFailure(java.lang.Exception e) A failure caused by an exception at some phase of the task.
void	onResponse(R r) Handle action response.
static <R> ContextPreservingActionListener<R>	wrapPreservingContext(ActionListener<R> listener, ThreadContext threadContext) Wraps the provided action listener in a ContextPreservingActionListener that will also copy the response headers when the ThreadContext.StoredContext is closed

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.elasticsearch.action.ActionListener

onFailure, onResponse, wrap

Constructor Detail

ContextPreservingActionListener

public ContextPreservingActionListener(java.util.function.Supplier<ThreadContext.StoredContext> contextSupplier,
                                       ActionListener<R> delegate)

Method Detail

onResponse

public void onResponse(R r)

Description copied from interface: ActionListener

Handle action response. This response may constitute a failure or a success but it is up to the listener to make that decision.

Specified by:

onResponse in interface ActionListener<R>

onFailure

public void onFailure(java.lang.Exception e)

Description copied from interface: ActionListener

A failure caused by an exception at some phase of the task.

Specified by:

onFailure in interface ActionListener<R>

wrapPreservingContext

public static <R> ContextPreservingActionListener<R> wrapPreservingContext(ActionListener<R> listener,
                                                                           ThreadContext threadContext)

Wraps the provided action listener in a ContextPreservingActionListener that will also copy the response headers when the ThreadContext.StoredContext is closed