You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by gz...@apache.org on 2015/10/30 21:10:07 UTC
[2/3] camel git commit: add parent to elasticsearch IndexRequest
add parent to elasticsearch IndexRequest
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/047d8e0f
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/047d8e0f
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/047d8e0f
Branch: refs/heads/master
Commit: 047d8e0f5658e038e3e14af13c92e8fa2b75dc16
Parents: 021a93b
Author: Jay Lapham <ja...@gmail.com>
Authored: Fri Oct 30 12:02:23 2015 -0500
Committer: Jay Lapham <ja...@gmail.com>
Committed: Fri Oct 30 12:02:23 2015 -0500
----------------------------------------------------------------------
.../converter/ElasticsearchActionRequestConverter.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/047d8e0f/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/converter/ElasticsearchActionRequestConverter.java
----------------------------------------------------------------------
diff --git a/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/converter/ElasticsearchActionRequestConverter.java b/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/converter/ElasticsearchActionRequestConverter.java
index 3a804f5..af7b214 100644
--- a/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/converter/ElasticsearchActionRequestConverter.java
+++ b/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/converter/ElasticsearchActionRequestConverter.java
@@ -51,6 +51,8 @@ public final class ElasticsearchActionRequestConverter {
} else {
return null;
}
+
+ indexRequest.parent(exchange.getIn().getHeader(ElasticsearchConstants.PARENT, String.class));
return indexRequest
.consistencyLevel(exchange.getIn().getHeader(