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, Writeable.Reader<T> reader)

Method Summary

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

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

wrap

Constructor Detail

TransportChannelResponseHandler

public TransportChannelResponseHandler(org.apache.logging.log4j.Logger logger,
                                       TransportChannel channel,
                                       java.lang.String extraInfoOnError,
                                       Writeable.Reader<T> reader)

Method Detail

read

public T read(StreamInput in)
       throws java.io.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:

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>