Repository: camel Updated Branches: refs/heads/master 70fe8c29b -> 25410ef00
Elasticsearch bulk_insert endpoint can now accept a list of IndexRequest or UpdateRequest objects Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/896e2dcb Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/896e2dcb Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/896e2dcb Branch: refs/heads/master Commit: 896e2dcb7469622233b7360fff74209e85bbb105 Parents: 70fe8c2 Author: Bryan Love <bryan.l...@iovation.com> Authored: Tue Jul 5 14:20:11 2016 -0700 Committer: Claus Ibsen <davscl...@apache.org> Committed: Wed Jul 6 08:42:11 2016 +0200 ---------------------------------------------------------------------- .../converter/ElasticsearchActionRequestConverter.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/896e2dcb/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 78f7534..b822943 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 @@ -44,6 +44,9 @@ public final class ElasticsearchActionRequestConverter { // Update requests private static UpdateRequest createUpdateRequest(Object document, Exchange exchange) { + if (document instanceof UpdateRequest){ + return (UpdateRequest)document; + } UpdateRequest updateRequest = new UpdateRequest(); if (document instanceof byte[]) { updateRequest.doc((byte[]) document); @@ -74,6 +77,9 @@ public final class ElasticsearchActionRequestConverter { // Index requests private static IndexRequest createIndexRequest(Object document, Exchange exchange) { + if (document instanceof IndexRequest){ + return (IndexRequest)document; + } IndexRequest indexRequest = new IndexRequest(); if (document instanceof byte[]) { indexRequest.source((byte[]) document);
