Package com.floragunn.searchsupport.diag

Class LogContextPreservingActionListener<R>

java.lang.Object

com.floragunn.searchsupport.diag.LogContextPreservingActionListener<R>

All Implemented Interfaces:

org.elasticsearch.action.ActionListener<R>

public final class LogContextPreservingActionListener<R>
extends Object
implements org.elasticsearch.action.ActionListener<R>

Restores the given ThreadContext.StoredContext and the given Log4j thread context once the listener is invoked

Nested Class Summary

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

org.elasticsearch.action.ActionListener.MappedActionListener<Response extends Object,MappedResponse extends Object>

Constructor Summary

Constructors

Constructor	Description
LogContextPreservingActionListener(Supplier<org.elasticsearch.common.util.concurrent.ThreadContext.StoredContext> contextSupplier, Map<String,String> logThreadContextMap, org.elasticsearch.action.ActionListener<R> delegate)

Method Summary

Modifier and Type	Method	Description
void	onFailure(Exception e)
void	onResponse(R r)
String	toString()
static <R> LogContextPreservingActionListener<R>	wrapPreservingContext(org.elasticsearch.action.ActionListener<R> listener, org.elasticsearch.common.util.concurrent.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, wait, wait, wait

Methods inherited from interface org.elasticsearch.action.ActionListener

map

Constructor Detail

LogContextPreservingActionListener

public LogContextPreservingActionListener(Supplier<org.elasticsearch.common.util.concurrent.ThreadContext.StoredContext> contextSupplier,
                                          Map<String,String> logThreadContextMap,
                                          org.elasticsearch.action.ActionListener<R> delegate)

Method Detail

onResponse

public void onResponse(R r)

Specified by:

onResponse in interface org.elasticsearch.action.ActionListener<R>

onFailure

public void onFailure(Exception e)

Specified by:

onFailure in interface org.elasticsearch.action.ActionListener<R>

toString

public String toString()

Overrides:

toString in class Object

wrapPreservingContext

public static <R> LogContextPreservingActionListener<R> wrapPreservingContext(org.elasticsearch.action.ActionListener<R> listener,
                                                                              org.elasticsearch.common.util.concurrent.ThreadContext threadContext)

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