Updated the code based on Claus's suggestions
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/253a18a8 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/253a18a8 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/253a18a8 Branch: refs/heads/master Commit: 253a18a8f6a6fb260e428992ecc238dda6eb0fa2 Parents: d652641 Author: Mark Webb <[email protected]> Authored: Tue May 16 23:26:09 2017 -0400 Committer: Claus Ibsen <[email protected]> Committed: Wed May 17 09:31:46 2017 +0200 ---------------------------------------------------------------------- .../org/apache/camel/component/mongodb/MongoDbProducer.java | 7 +------ .../camel/component/mongodb/MongoDbFindOperationTest.java | 1 - 2 files changed, 1 insertion(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/253a18a8/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbProducer.java b/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbProducer.java index 8b8403a..814315d 100644 --- a/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbProducer.java +++ b/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbProducer.java @@ -302,12 +302,7 @@ public class MongoDbProducer extends DefaultProducer { // get the parameters out of the Exchange Header String distinctFieldName = exchange.getIn().getHeader(MongoDbConstants.DISTINCT_QUERY_FIELD, String.class); - BasicDBObject query = null; - // do not run around looking for a type converter unless there is a need for it - if (exchange.getIn().getBody() != null) { - query = exchange.getIn().getBody(BasicDBObject.class); - } - + BasicDBObject query = exchange.getIn().getBody(BasicDBObject.class); DistinctIterable<String> ret = null; if (query != null) { ret = dbCol.distinct(distinctFieldName, query, String.class); http://git-wip-us.apache.org/repos/asf/camel/blob/253a18a8/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbFindOperationTest.java ---------------------------------------------------------------------- diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbFindOperationTest.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbFindOperationTest.java index 8218049..9aa7bc2 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbFindOperationTest.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbFindOperationTest.java @@ -158,7 +158,6 @@ public class MongoDbFindOperationTest extends AbstractMongoDbTest { headers.put(MongoDbConstants.NUM_TO_SKIP, numToSkip); headers.put(MongoDbConstants.LIMIT, 100); Object result = template.requestBodyAndHeaders("direct:findAll", (Object) null, headers); - System.out.println(result.getClass()); assertTrue("Result is not of type List", result instanceof List); @SuppressWarnings("unchecked")
