Fixed CS
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/72281e0d Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/72281e0d Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/72281e0d Branch: refs/heads/master Commit: 72281e0d49ffbfe8941d1d64b4466d43b27a8246 Parents: 8a462f0 Author: Andrea Cosentino <anco...@gmail.com> Authored: Wed Aug 24 11:31:57 2016 +0200 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Wed Aug 24 11:31:57 2016 +0200 ---------------------------------------------------------------------- .../component/couchdb/CouchDbProducer.java | 24 ++++++++++---------- 1 file changed, 12 insertions(+), 12 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/72281e0d/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbProducer.java b/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbProducer.java index 017768a..d5d5f95 100644 --- a/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbProducer.java +++ b/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbProducer.java @@ -51,18 +51,18 @@ public class CouchDbProducer extends DefaultProducer { exchange.getIn().setHeader(CouchDbConstants.HEADER_DOC_REV, save.getRev()); exchange.getIn().setHeader(CouchDbConstants.HEADER_DOC_ID, save.getId()); } else { - if (operation.equalsIgnoreCase("DELETE")) { - Response delete = deleteJsonElement(json); - if (delete == null) { - throw new CouchDbException("Could not delete document [unknown reason]", exchange); - } + if (operation.equalsIgnoreCase("DELETE")) { + Response delete = deleteJsonElement(json); + if (delete == null) { + throw new CouchDbException("Could not delete document [unknown reason]", exchange); + } - if (log.isTraceEnabled()) { - log.trace("Document saved [_id={}, _rev={}]", delete.getId(), delete.getRev()); + if (log.isTraceEnabled()) { + log.trace("Document saved [_id={}, _rev={}]", delete.getId(), delete.getRev()); + } + exchange.getIn().setHeader(CouchDbConstants.HEADER_DOC_REV, delete.getRev()); + exchange.getIn().setHeader(CouchDbConstants.HEADER_DOC_ID, delete.getId()); } - exchange.getIn().setHeader(CouchDbConstants.HEADER_DOC_REV, delete.getRev()); - exchange.getIn().setHeader(CouchDbConstants.HEADER_DOC_ID, delete.getId()); - } } } @@ -102,8 +102,8 @@ public class CouchDbProducer extends DefaultProducer { JsonObject obj = (JsonObject) json; delete = couchClient.remove(obj); } else { - delete = couchClient.remove(json); + delete = couchClient.remove(json); } - return delete; + return delete; } }
