org.elasticsearch.transport

Class TransportChannelResponseHandler<T extends TransportResponse>

java.lang.Object

org.elasticsearch.transport.TransportChannelResponseHandler<T>

All Implemented Interfaces:

TransportResponseHandler<T>

public class TransportChannelResponseHandler<T extends TransportResponse>
extends java.lang.Object
implements TransportResponseHandler<T>

Base class for delegating transport response to a transport channel

Constructor Summary

Constructors

Constructor and Description
TransportChannelResponseHandler(org.apache.logging.log4j.Logger logger, TransportChannel channel, java.lang.String extraInfoOnError, java.util.function.Supplier<T> responseSupplier)

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

TransportChannelResponseHandler

public TransportChannelResponseHandler(org.apache.logging.log4j.Logger logger,
                                       TransportChannel channel,
                                       java.lang.String extraInfoOnError,
                                       java.util.function.Supplier<T> responseSupplier)

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>