allow Client implementation to be set via the config file

Author: Matt Hartzler

modules/elasticsearch/src/main/java/org/elasticsearch/client/node/NodeClientModule.java

@@ -24,16 +24,22 @@
 import org.elasticsearch.client.ClusterAdminClient;
 import org.elasticsearch.client.IndicesAdminClient;
 import org.elasticsearch.common.inject.AbstractModule;
+import org.elasticsearch.common.settings.Settings;
 
 /**
  * @author kimchy (shay.banon)
  */
 public class NodeClientModule extends AbstractModule {
+    private final Settings settings;
+
+    public NodeClientModule(Settings settings) {
+        this.settings = settings;
+    }
 
     @Override protected void configure() {
         bind(ClusterAdminClient.class).to(NodeClusterAdminClient.class).asEagerSingleton();
         bind(IndicesAdminClient.class).to(NodeIndicesAdminClient.class).asEagerSingleton();
         bind(AdminClient.class).to(NodeAdminClient.class).asEagerSingleton();
-        bind(Client.class).to(NodeClient.class).asEagerSingleton();
+        bind(Client.class).to(settings.getAsClass("client.type", NodeClient.class, "org.elasticsearch.client.node", "Client")).asEagerSingleton();
     }
 }

modules/elasticsearch/src/main/java/org/elasticsearch/node/internal/InternalNode.java

@@ -141,7 +141,7 @@ public InternalNode(Settings pSettings, boolean loadConfigSettings) throws Elast
         modules.add(new TransportActionModule());
         modules.add(new MonitorModule(settings));
         modules.add(new GatewayModule(settings));
-        modules.add(new NodeClientModule());
+        modules.add(new NodeClientModule(settings));
 
         injector = modules.createInjector();
 
@@ -320,4 +320,4 @@ public static void main(String[] args) throws Exception {
             }
         });
     }
-}
+}