public abstract class TransportAction<Request extends ActionRequest,Response extends ActionResponse> extends AbstractComponent
Modifier and Type | Field and Description |
---|---|
protected String |
actionName |
protected ThreadPool |
threadPool |
componentSettings, logger, settings
Modifier | Constructor and Description |
---|---|
protected |
TransportAction(Settings settings,
String actionName,
ThreadPool threadPool,
ActionFilters actionFilters) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
doExecute(Request request,
ActionListener<Response> listener) |
ActionFuture<Response> |
execute(Request request) |
void |
execute(Request request,
ActionListener<Response> listener) |
protected boolean |
forceThreadedListener() |
nodeName
protected final ThreadPool threadPool
protected final String actionName
protected TransportAction(Settings settings, String actionName, ThreadPool threadPool, ActionFilters actionFilters)
public final ActionFuture<Response> execute(Request request) throws ElasticsearchException
ElasticsearchException
public final void execute(Request request, ActionListener<Response> listener)
protected boolean forceThreadedListener()
protected abstract void doExecute(Request request, ActionListener<Response> listener)
Copyright © 2009–2015. All rights reserved.