Package org.elasticsearch.action

Class ActionListenerResponseHandler<Response extends TransportResponse>

java.lang.Object

org.elasticsearch.action.ActionListenerResponseHandler<Response>

All Implemented Interfaces:

Writeable.Reader<Response>, TransportResponseHandler<Response>

public class ActionListenerResponseHandler<Response extends TransportResponse>
extends 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).

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.transport.TransportResponseHandler

TransportResponseHandler.Empty

Constructor Summary

Constructors

Constructor	Description
ActionListenerResponseHandler(ActionListener<? super Response> listener, Writeable.Reader<Response> reader)
ActionListenerResponseHandler(ActionListener<? super Response> listener, Writeable.Reader<Response> reader, String executor)

Method Summary

Modifier and Type	Method	Description
String	executor()
void	handleException(TransportException e)
void	handleResponse(Response response)
Response	read(StreamInput in)	Read V-type value from a stream.
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.transport.TransportResponseHandler

wrap

Constructor Details

ActionListenerResponseHandler

public ActionListenerResponseHandler(ActionListener<? super Response> listener,
 Writeable.Reader<Response> reader,
 String executor)

ActionListenerResponseHandler

public ActionListenerResponseHandler(ActionListener<? super Response> listener,
 Writeable.Reader<Response> reader)

Method Details

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>

executor

public String executor()

Specified by:

executor in interface TransportResponseHandler<Response extends TransportResponse>

read

public Response read(StreamInput in)
              throws IOException

Description copied from interface: Writeable.Reader

Read V-type value from a stream.

Specified by:

read in interface Writeable.Reader<Response extends TransportResponse>

Parameters:

in - Input to read the value from

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object