Module org.elasticsearch.server

Package org.elasticsearch.transport

Interface TransportResponseHandler<T extends TransportResponse>

All Superinterfaces:

Writeable.Reader<T>

All Known Implementing Classes:

ActionListenerResponseHandler, CleanableResponseHandler, TransportResponseHandler.Empty, TransportService.ContextRestoreResponseHandler

public interface TransportResponseHandler<T extends TransportResponse>
extends Writeable.Reader<T>

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	TransportResponseHandler.Empty	Implementation of TransportResponseHandler that handles the empty response TransportResponse.Empty.

Field Summary

Fields

Modifier and Type	Field	Description
static final Executor	TRANSPORT_WORKER	Alias for EsExecutors.DIRECT_EXECUTOR_SERVICE which emphasises that non-forking transport response handlers do their work on the transport worker (unless the request is being sent to the local node, but that's not the common case).

Method Summary

Modifier and Type	Method	Description
static TransportResponseHandler.Empty	empty(Executor executor, ActionListener<Void> listener)
Executor	executor()
void	handleException(TransportException exp)
void	handleResponse(T response)

Methods inherited from interface org.elasticsearch.common.io.stream.Writeable.Reader

read

Field Details

TRANSPORT_WORKER

static final Executor TRANSPORT_WORKER

Alias for EsExecutors.DIRECT_EXECUTOR_SERVICE which emphasises that non-forking transport response handlers do their work on the transport worker (unless the request is being sent to the local node, but that's not the common case). You must only use this executor for handling responses to very performance-critical actions, and even then only if the deserialization and handling work is very cheap, because this executor will perform all the work for responses from remote nodes on the receiving transport worker itself.

Method Details

executor

Executor executor()

Returns:

the executor to use to deserialize the response and notify the listener. You must only use EsExecutors.DIRECT_EXECUTOR_SERVICE (or equivalently TRANSPORT_WORKER) for very performance-critical actions, and even then only if the deserialization and handling work is very cheap, because this executor will perform all the work for responses from remote nodes on the receiving transport worker itself.

handleResponse

void handleResponse(T response)

handleException

void handleException(TransportException exp)

empty

static TransportResponseHandler.Empty empty(Executor executor,
 ActionListener<Void> listener)