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

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

public class TransportActionNodeProxy<Request extends ActionRequest,Response extends ActionResponse>
extends AbstractComponent

A generic proxy that will execute the given action against a specific node.

Field Summary

protected TransportService

transportService

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

componentSettings, logger, settings

Constructor Summary

TransportActionNodeProxy(Settings settings, GenericAction<Request,Response> action, TransportService transportService)

Method Summary

ActionFuture<Response>	execute(DiscoveryNode node, Request request)
void	execute(DiscoveryNode node, 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

transportService

protected final TransportService transportService

Constructor Detail

TransportActionNodeProxy

@Inject
public TransportActionNodeProxy(Settings settings,
                                       GenericAction<Request,Response> action,
                                       TransportService transportService)

Method Detail

execute

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

Throws:

ElasticSearchException

execute

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