org.elasticsearch.action

Class ActionListenerResponseHandler<Response extends TransportResponse>

java.lang.Object

org.elasticsearch.action.ActionListenerResponseHandler<Response>

All Implemented Interfaces:

TransportResponseHandler<Response>

public class ActionListenerResponseHandler<Response extends TransportResponse>
extends java.lang.Object
implements TransportResponseHandler<Response>

A simple base class for action response listeners, defaulting to using the SAME executor (as its very common on response handlers).

Constructor Summary

Constructors

Constructor and Description
ActionListenerResponseHandler(ActionListener<Response> listener, java.util.function.Supplier<Response> responseSupplier)

Method Summary

Modifier and Type	Method and Description
java.lang.String	executor()
void	handleException(TransportException e)
void	handleResponse(Response response)
Response	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

ActionListenerResponseHandler

public ActionListenerResponseHandler(ActionListener<Response> listener,
                                     java.util.function.Supplier<Response> responseSupplier)

Method Detail

handleResponse

public void handleResponse(Response response)

Specified by:

handleResponse in interface TransportResponseHandler<Response extends TransportResponse>

handleException

public void handleException(TransportException e)

Specified by:

handleException in interface TransportResponseHandler<Response extends TransportResponse>

newInstance

public Response 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<Response extends TransportResponse>

Returns:

a new response copy.

executor

public java.lang.String executor()

Specified by:

executor in interface TransportResponseHandler<Response extends TransportResponse>