honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

use existing constant to check whether client is a transport client

This commit is contained in:
javanna 2015-11-02 15:27:56 +01:00 committed by Luca Cavanna
parent 61d5ccbe7d
commit 8425d26b70
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
plugins/ingest/src/main/java/org/elasticsearch/plugin/ingest/IngestPlugin.java
View File

@ -22,6 +22,7 @@ package org.elasticsearch.plugin.ingest;
import org.elasticsearch.action.ActionModule;
import org.elasticsearch.client.Client;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.component.LifecycleComponent;
import org.elasticsearch.common.inject.Module;
import org.elasticsearch.common.settings.Settings;
@ -56,7 +57,7 @@ public class IngestPlugin extends Plugin {
public IngestPlugin(Settings nodeSettings) {
this.nodeSettings = nodeSettings;
transportClient = "transport".equals(nodeSettings.get(Client.CLIENT_TYPE_SETTING));
transportClient = TransportClient.CLIENT_TYPE.equals(nodeSettings.get(Client.CLIENT_TYPE_SETTING));
}
@Override
@ -95,7 +96,7 @@ public class IngestPlugin extends Plugin {
}
public void onModule(ActionModule module) {
if (!transportClient) {
if (transportClient == false) {
module.registerFilter(IngestActionFilter.class);
}
module.registerAction(PutPipelineAction.INSTANCE, PutPipelineTransportAction.class);
@ -108,5 +109,4 @@ public class IngestPlugin extends Plugin {
restModule.addRestAction(RestGetPipelineAction.class);
restModule.addRestAction(RestDeletePipelineAction.class);
}
}