java.lang.Object

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

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

Restores the given ThreadContext.StoredContext once the listener is invoked

Method Summary

Modifier and Type	Method	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

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

Constructor Details
- ContextPreservingActionListener
  
  public ContextPreservingActionListener(java.util.function.Supplier<ThreadContext.StoredContext> contextSupplier, ActionListener<R> delegate)
Method Details
- 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

Class ContextPreservingActionListener<R>