Repository: camel Updated Branches: refs/heads/camel-2.19.x 2ad2cc021 -> 93ec6f3a7 refs/heads/master 0469d2a76 -> 5de4ed40f
CAMEL-11848: Check for null value when getting key "capped" of collection stats (key/value might not exist in MongoDB 2.6) Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/3fea2a2c Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/3fea2a2c Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/3fea2a2c Branch: refs/heads/master Commit: 3fea2a2c6c6a666656178f191bdf1012fa59ea94 Parents: 0469d2a Author: Frank Wein <frank.w...@fau.de> Authored: Wed Sep 27 15:17:09 2017 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Wed Sep 27 15:39:16 2017 +0200 ---------------------------------------------------------------------- .../apache/camel/component/mongodb/MongoDbTailingProcess.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/3fea2a2c/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbTailingProcess.java ---------------------------------------------------------------------- diff --git a/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbTailingProcess.java b/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbTailingProcess.java index 2a1d574..a93cd11 100644 --- a/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbTailingProcess.java +++ b/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbTailingProcess.java @@ -94,7 +94,9 @@ public class MongoDbTailingProcess implements Runnable { } private Boolean isCollectionCapped() { - return endpoint.getMongoDatabase().runCommand(createCollStatsCommand()).getBoolean(CAPPED_KEY); + // A non-capped collection does not return a "capped" key/value, so we have to deal with null here + Boolean result = endpoint.getMongoDatabase().runCommand(createCollStatsCommand()).getBoolean(CAPPED_KEY); + return (result != null ? result : false); } private BasicDBObject createCollStatsCommand() {
