Fixed CS. This closes #1368
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/a9fe0d69 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a9fe0d69 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a9fe0d69 Branch: refs/heads/master Commit: a9fe0d69ebdba02cc562462957386275fff51970 Parents: 52e7be8 Author: Claus Ibsen <davscl...@apache.org> Authored: Fri Dec 30 09:44:50 2016 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Fri Dec 30 09:44:50 2016 +0100 ---------------------------------------------------------------------- .../camel/component/elasticsearch/ElasticsearchProducer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/a9fe0d69/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchProducer.java b/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchProducer.java index 75164d2..55e9d3c 100644 --- a/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchProducer.java +++ b/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchProducer.java @@ -170,7 +170,7 @@ public class ElasticsearchProducer extends DefaultProducer { MultiSearchRequest multiSearchRequest = message.getBody(MultiSearchRequest.class); message.setBody(client.multiSearch(multiSearchRequest)); } else if (ElasticsearchConstants.OPERATION_DELETE_INDEX.equals(operation)) { - DeleteIndexRequest deleteIndexRequest = message.getBody(DeleteIndexRequest.class); + DeleteIndexRequest deleteIndexRequest = message.getBody(DeleteIndexRequest.class); message.setBody(client.admin().indices().delete(deleteIndexRequest).actionGet()); } else { throw new IllegalArgumentException(ElasticsearchConstants.PARAM_OPERATION + " value '" + operation + "' is not supported");
