Skip to content

Commit 7285b34

Browse files
author
Matt Hartzler
committed
allow Client implementation to be set via the config file
1 parent ca67c12 commit 7285b34

File tree

2 files changed

+8
-3
lines changed

2 files changed

+8
-3
lines changed

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

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,11 +29,16 @@
2929
* @author kimchy (shay.banon)
3030
*/
3131
public class NodeClientModule extends AbstractModule {
32+
private final Settings settings;
33+
34+
public NodeClientModule(Settings settings) {
35+
this.settings = settings;
36+
}
3237

3338
@Override protected void configure() {
3439
bind(ClusterAdminClient.class).to(NodeClusterAdminClient.class).asEagerSingleton();
3540
bind(IndicesAdminClient.class).to(NodeIndicesAdminClient.class).asEagerSingleton();
3641
bind(AdminClient.class).to(NodeAdminClient.class).asEagerSingleton();
37-
bind(Client.class).to(NodeClient.class).asEagerSingleton();
42+
bind(Client.class).to(settings.getAsClass("client.type", NodeClient.class, "org.elasticsearch.client.node", "Client")).asEagerSingleton();
3843
}
3944
}

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -141,7 +141,7 @@ public InternalNode(Settings pSettings, boolean loadConfigSettings) throws Elast
141141
modules.add(new TransportActionModule());
142142
modules.add(new MonitorModule(settings));
143143
modules.add(new GatewayModule(settings));
144-
modules.add(new NodeClientModule());
144+
modules.add(new NodeClientModule(settings));
145145

146146
injector = modules.createInjector();
147147

@@ -320,4 +320,4 @@ public static void main(String[] args) throws Exception {
320320
}
321321
});
322322
}
323-
}
323+
}

0 commit comments

Comments
 (0)