Module org.elasticsearch.server

Package org.elasticsearch.cluster.coordination

Class CleanableResponseHandler<T extends TransportResponse>

java.lang.Object

org.elasticsearch.action.ActionListenerResponseHandler<T>

org.elasticsearch.cluster.coordination.CleanableResponseHandler<T>

All Implemented Interfaces:

Writeable.Reader<T>, TransportResponseHandler<T>

public class CleanableResponseHandler<T extends TransportResponse>
extends ActionListenerResponseHandler<T>

Combines an ActionListenerResponseHandler with an ActionListener.runAfter action, but with an explicit type so that tests that simulate reboots can release resources without invoking the listener.

Nested Class Summary

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

TransportResponseHandler.Empty

Field Summary

Fields inherited from class org.elasticsearch.action.ActionListenerResponseHandler

listener

Constructor Summary

Constructors

Constructor	Description
CleanableResponseHandler(ActionListener<? super T> listener, Writeable.Reader<T> reader, String executor, Runnable cleanup)

Method Summary

Modifier and Type	Method	Description
void	runCleanup()

Methods inherited from class org.elasticsearch.action.ActionListenerResponseHandler

executor, handleException, handleResponse, read, toString

Methods inherited from class java.lang.Object

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

Constructor Details

CleanableResponseHandler

public CleanableResponseHandler(ActionListener<? super T> listener,
 Writeable.Reader<T> reader,
 String executor,
 Runnable cleanup)

Method Details

runCleanup

public void runCleanup()