Package org.elasticsearch.transport

Class TransportService.ContextRestoreResponseHandler<T extends TransportResponse>

java.lang.Object

org.elasticsearch.transport.TransportService.ContextRestoreResponseHandler<T>

All Implemented Interfaces:

Writeable.Reader<T>, TransportResponseHandler<T>

Enclosing class:

TransportService

public static final class TransportService.ContextRestoreResponseHandler<T extends TransportResponse>
extends Object
implements TransportResponseHandler<T>

This handler wrapper ensures that the response thread executes with the correct thread context. Before any of the handle methods are invoked we restore the context.

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.transport.TransportResponseHandler

TransportResponseHandler.Empty

Constructor Summary

Constructors

Constructor	Description
ContextRestoreResponseHandler(Supplier<ThreadContext.StoredContext> contextSupplier, TransportResponseHandler<T> delegate)

Method Summary

Modifier and Type	Method	Description
String	executor()
void	handleException(TransportException exp)
void	handleResponse(T response)
T	read(StreamInput in)	Read V-type value from a stream.
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.transport.TransportResponseHandler

wrap

Constructor Details

ContextRestoreResponseHandler

public ContextRestoreResponseHandler(Supplier<ThreadContext.StoredContext> contextSupplier,
 TransportResponseHandler<T> delegate)

Method Details

read

public T read(StreamInput in)
       throws IOException

Description copied from interface: Writeable.Reader

Read V-type value from a stream.

Specified by:

read in interface Writeable.Reader<T extends TransportResponse>

Parameters:

in - Input to read the value from

Throws:

IOException

handleResponse

public void handleResponse(T response)

Specified by:

handleResponse in interface TransportResponseHandler<T extends TransportResponse>

handleException

public void handleException(TransportException exp)

Specified by:

handleException in interface TransportResponseHandler<T extends TransportResponse>

executor

public String executor()

Specified by:

executor in interface TransportResponseHandler<T extends TransportResponse>

toString

public String toString()

Overrides:

toString in class Object