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 java.lang.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.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
java.lang.String	executor()
void	handleException(TransportException exp)
void	handleResponse(T response)
T	read(StreamInput in)	deserializes a new instance of the return type from the stream.
java.lang.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

newInstance

Constructor Detail

ContextRestoreResponseHandler

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

Method Detail

read

public T read(StreamInput in)
       throws java.io.IOException

Description copied from interface: TransportResponseHandler

deserializes a new instance of the return type from the stream. called by the infra when de-serializing the response.

Specified by:

read in interface TransportResponseHandler<T extends TransportResponse>

Specified by:

read in interface Writeable.Reader<T extends TransportResponse>

Parameters:

in - Input to read the value from

Returns:

the deserialized response.

Throws:

java.io.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 java.lang.String executor()

Specified by:

executor in interface TransportResponseHandler<T extends TransportResponse>

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object