org.elasticsearch.transport

Class TransportService.ContextRestoreResponseHandler<T extends TransportResponse>

java.lang.Object

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

All Implemented Interfaces:

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 the4 handle methods are invoked we restore the context.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
java.lang.String	executor()
void	handleException(TransportException exp)
void	handleResponse(T response)
T	newInstance() creates a new instance of the return type from the remote call.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ContextRestoreResponseHandler

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

Method Detail

newInstance

public T newInstance()

Description copied from interface: TransportResponseHandler

creates a new instance of the return type from the remote call. called by the infra before de-serializing the response.

Specified by:

newInstance in interface TransportResponseHandler<T extends TransportResponse>

Returns:

a new response copy.

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