CAMEL-6515 camel-mongodb: Upgrade MongoDB driver from 2.9.1 to 2.11.2
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/b62aabee Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/b62aabee Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/b62aabee Branch: refs/heads/camel-2.11.x Commit: b62aabee36194687e100b62bcbd33b4d7d5637c5 Parents: 3ca6b2f Author: RauÌl Kripalani <ra...@apache.org> Authored: Sun Jul 7 23:06:36 2013 +0100 Committer: RauÌl Kripalani <ra...@apache.org> Committed: Sun Jul 7 23:40:11 2013 +0100 ---------------------------------------------------------------------- .../org/apache/camel/component/mongodb/MongoDbOperation.java | 2 +- .../apache/camel/component/mongodb/MongoDbTailingProcess.java | 3 +++ .../org/apache/camel/component/mongodb/AbstractMongoDbTest.java | 5 +++-- .../apache/camel/component/mongodb/MongoDbOperationsTest.java | 1 - parent/pom.xml | 2 +- 5 files changed, 8 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/b62aabee/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbOperation.java ---------------------------------------------------------------------- diff --git a/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbOperation.java b/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbOperation.java index bb6ee6a..fe7570f 100644 --- a/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbOperation.java +++ b/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbOperation.java @@ -33,7 +33,7 @@ public enum MongoDbOperation { // delete operations remove, - //aggregat + // aggregate aggregate, // others http://git-wip-us.apache.org/repos/asf/camel/blob/b62aabee/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 42cb4f1..079dc0b 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 @@ -160,6 +160,9 @@ public class MongoDbTailingProcess implements Runnable { if (keepRunning) { LOG.debug("Cursor not found exception from MongoDB, will regenerate cursor. This is normal behaviour with tailable cursors.", e); } + } catch (NullPointerException e) { + // The MongoDB Java Driver throws this uncontrolled NPE when the cursor is closed while blocked at DBCursor#hasMore. + // See https://jira.mongodb.org/browse/JAVA-605 } // the loop finished, persist the lastValue just in case we are shutting down http://git-wip-us.apache.org/repos/asf/camel/blob/b62aabee/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/AbstractMongoDbTest.java ---------------------------------------------------------------------- diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/AbstractMongoDbTest.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/AbstractMongoDbTest.java index f6f4698..f6cb381 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/AbstractMongoDbTest.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/AbstractMongoDbTest.java @@ -25,7 +25,8 @@ import com.mongodb.DB; import com.mongodb.DBCollection; import com.mongodb.DBObject; import com.mongodb.Mongo; -import com.mongodb.MongoURI; +import com.mongodb.MongoClient; +import com.mongodb.MongoClientURI; import com.mongodb.WriteConcern; import com.mongodb.util.JSON; @@ -72,7 +73,7 @@ public abstract class AbstractMongoDbTest extends CamelTestSupport { properties.load(is); // ping Mongo and populate db and collection try { - mongo = new Mongo(new MongoURI(properties.getProperty("mongodb.connectionURI"))); + mongo = new MongoClient(new MongoClientURI(properties.getProperty("mongodb.connectionURI"))); mongo.getDatabaseNames(); dbName = properties.getProperty("mongodb.testDb"); db = mongo.getDB(dbName); http://git-wip-us.apache.org/repos/asf/camel/blob/b62aabee/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbOperationsTest.java ---------------------------------------------------------------------- diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbOperationsTest.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbOperationsTest.java index 3176abe..51caa1c 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbOperationsTest.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbOperationsTest.java @@ -25,7 +25,6 @@ import com.mongodb.WriteResult; import com.mongodb.util.JSON; import org.apache.camel.builder.RouteBuilder; - import org.junit.Test; public class MongoDbOperationsTest extends AbstractMongoDbTest { http://git-wip-us.apache.org/repos/asf/camel/blob/b62aabee/parent/pom.xml ---------------------------------------------------------------------- diff --git a/parent/pom.xml b/parent/pom.xml index 925da57..a43de9d 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -277,7 +277,7 @@ <mina2-version>2.0.7</mina2-version> <mock-javamail-version>1.7</mock-javamail-version> <mockito-version>1.9.5</mockito-version> - <mongo-java-driver-version>2.9.1</mongo-java-driver-version> + <mongo-java-driver-version>2.11.2</mongo-java-driver-version> <mqtt-client-version>1.4</mqtt-client-version> <msv-version>20050913</msv-version> <mvel-version>2.1.3.Final</mvel-version>
