You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2017/05/17 07:34:14 UTC
[3/3] camel git commit: Updated the code based on Claus's suggestions
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 <mw...@srcinc.com>
Authored: Tue May 16 23:26:09 2017 -0400
Committer: Claus Ibsen <da...@apache.org>
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")