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/a2ac18a1 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a2ac18a1 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a2ac18a1 Branch: refs/heads/camel-2.10.x Commit: a2ac18a1d85eec48b6712e7d42ea23d3d841926f Parents: 1bd4d45 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:18:10 2013 +0100 ---------------------------------------------------------------------- .../org/apache/camel/component/mongodb/MongoDbOperation.java | 2 +- .../apache/camel/component/mongodb/MongoDbTailingProcess.java | 3 +++ .../apache/camel/component/mongodb/AbstractMongoDbTest.java | 6 +++--- .../apache/camel/component/mongodb/MongoDbOperationsTest.java | 1 - parent/pom.xml | 2 +- 5 files changed, 8 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/a2ac18a1/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/a2ac18a1/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/a2ac18a1/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 d51213e..66f2a5c 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; @@ -40,7 +41,6 @@ import org.junit.After; import org.junit.Assume; import org.junit.Before; import org.junit.BeforeClass; -import org.junit.Test; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; @@ -71,7 +71,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/a2ac18a1/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 87fc9ce..15a751f 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 @@ -26,7 +26,6 @@ import com.mongodb.util.JSON; import org.apache.camel.Exchange; 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/a2ac18a1/parent/pom.xml ---------------------------------------------------------------------- diff --git a/parent/pom.xml b/parent/pom.xml index d791a45..f7980db 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -151,7 +151,7 @@ <mina-version>1.1.7</mina-version> <mina2-version>2.0.7</mina2-version> <mockito-version>1.9.0</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> <mvel-version>2.1.3.Final</mvel-version> <mybatis-version>3.1.1</mybatis-version>
