Package org.elasticsearch.transport

Class TransportChannelResponseHandler<T extends TransportResponse>

java.lang.Object

org.elasticsearch.transport.TransportChannelResponseHandler<T>

All Implemented Interfaces:

Writeable.Reader<T>, 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	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	Description
java.lang.String	executor()
void	handleException(TransportException exp)
void	handleResponse(T response)
T	newInstance()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.transport.TransportResponseHandler

read

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()

Specified by:

newInstance in interface TransportResponseHandler<T extends TransportResponse>

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>