org.elasticsearch.action.support
Class TransportAction<Request extends ActionRequest,Response extends ActionResponse>

java.lang.Object
  org.elasticsearch.common.component.AbstractComponent
      org.elasticsearch.action.support.TransportAction<Request,Response>

Direct Known Subclasses:

TransportBroadcastOperationAction, TransportBulkAction, TransportIndexReplicationOperationAction, TransportIndicesReplicationOperationAction, TransportInstanceSingleOperationAction, TransportMasterNodeOperationAction, TransportMoreLikeThisAction, TransportMultiGetAction, TransportMultiSearchAction, TransportNodesOperationAction, TransportSearchAction, TransportSearchScrollAction, TransportSearchTypeAction, TransportShardReplicationOperationAction, TransportShardSingleOperationAction, TransportSingleCustomOperationAction

public abstract class TransportAction<Request extends ActionRequest,Response extends ActionResponse>
extends AbstractComponent

Field Summary

protected ThreadPool

threadPool

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

componentSettings, logger, settings

Constructor Summary

protected

TransportAction(Settings settings, ThreadPool threadPool)

Method Summary

protected abstract void	doExecute(Request request, ActionListener<Response> listener)
ActionFuture<Response>	execute(Request request)
void	execute(Request request, ActionListener<Response> listener)

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

nodeName

Methods inherited from class java.lang.Object

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

Field Detail

threadPool

protected final ThreadPool threadPool

Constructor Detail

TransportAction

protected TransportAction(Settings settings,
                          ThreadPool threadPool)

Method Detail

execute

public ActionFuture<Response> execute(Request request)
                                                      throws ElasticSearchException

Throws:

ElasticSearchException

execute

public void execute(Request request,
                    ActionListener<Response> listener)

doExecute

protected abstract void doExecute(Request request,
                                  ActionListener<Response> listener)