Package org.elasticsearch.rest.action

Class RestCancellableNodeClient

java.lang.Object

org.elasticsearch.client.support.AbstractClient

org.elasticsearch.client.FilterClient

org.elasticsearch.rest.action.RestCancellableNodeClient

All Implemented Interfaces:

Closeable, AutoCloseable, Client, ElasticsearchClient, org.elasticsearch.core.Releasable

public class RestCancellableNodeClient
extends FilterClient

A Client that cancels tasks executed locally when the provided HttpChannel is closed before completion.

Field Summary

Fields inherited from class org.elasticsearch.client.FilterClient

in

Fields inherited from class org.elasticsearch.client.support.AbstractClient

logger, settings

Fields inherited from interface org.elasticsearch.client.Client

CLIENT_TYPE_SETTING_S

Constructor Summary

Constructors

Constructor	Description
RestCancellableNodeClient(NodeClient client, HttpChannel httpChannel)

Method Summary

Modifier and Type	Method	Description
<Request extends ActionRequest, Response extends ActionResponse> void	doExecute(ActionType<Response> action, Request request, ActionListener<Response> listener)
static int	getNumChannels()	Returns the number of channels tracked globally.

Methods inherited from class org.elasticsearch.client.FilterClient

close, getRemoteClusterClient, in

Methods inherited from class org.elasticsearch.client.support.AbstractClient

admin, bulk, bulk, clearScroll, clearScroll, delete, delete, execute, execute, explain, explain, fieldCaps, fieldCaps, filterWithHeader, get, get, index, index, multiGet, multiGet, multiSearch, multiSearch, multiTermVectors, multiTermVectors, prepareBulk, prepareBulk, prepareClearScroll, prepareDelete, prepareDelete, prepareExplain, prepareFieldCaps, prepareGet, prepareGet, prepareIndex, prepareIndex, prepareIndex, prepareMultiGet, prepareMultiSearch, prepareMultiTermVectors, prepareSearch, prepareSearchScroll, prepareTermVectors, prepareTermVectors, prepareUpdate, prepareUpdate, search, search, searchScroll, searchScroll, settings, termVectors, termVectors, threadPool, update, update

Methods inherited from class java.lang.Object

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

Constructor Details

RestCancellableNodeClient

public RestCancellableNodeClient(NodeClient client,
 HttpChannel httpChannel)

Method Details

getNumChannels

public static int getNumChannels()

Returns the number of channels tracked globally.

doExecute

public <Request extends ActionRequest,
Response extends ActionResponse>
void doExecute(ActionType<Response> action,
 Request request,
 ActionListener<Response> listener)

Overrides:

doExecute in class FilterClient