You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2015/05/29 05:15:56 UTC
camel git commit: CAMEL-8816 Fixed the elasticsearch component start
up issue when using the local elasticsearch instance
Repository: camel
Updated Branches:
refs/heads/master a412cd90b -> 919673cbf
CAMEL-8816 Fixed the elasticsearch component start up issue when using the local elasticsearch instance
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/919673cb
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/919673cb
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/919673cb
Branch: refs/heads/master
Commit: 919673cbf3cca2082466e499b1b0fb033ae82f63
Parents: a412cd9
Author: Willem Jiang <wi...@gmail.com>
Authored: Fri May 29 11:15:18 2015 +0800
Committer: Willem Jiang <wi...@gmail.com>
Committed: Fri May 29 11:15:18 2015 +0800
----------------------------------------------------------------------
.../apache/camel/component/elasticsearch/ElasticsearchEndpoint.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/919673cb/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchEndpoint.java b/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchEndpoint.java
index 0077ce3..07ff1e0 100644
--- a/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchEndpoint.java
+++ b/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchEndpoint.java
@@ -93,6 +93,7 @@ public class ElasticsearchEndpoint extends DefaultEndpoint {
if (!configuration.isLocal() && configuration.getClusterName() != null) {
builder.clusterName(configuration.getClusterName());
}
+ builder.getSettings().classLoader(Settings.class.getClassLoader());
node = builder.node();
client = node.client();
}