diff --git a/pom.xml b/pom.xml
index d12871a5fb92f48c6b2726805dae0af26d238668..fef1b64bdb16b8c4d86d6c171d0059e0bef103b6 100644
--- a/pom.xml
+++ b/pom.xml
@@ -337,7 +337,7 @@
<dependency>
<groupId>de.flapdoodle.embed</groupId>
<artifactId>de.flapdoodle.embed.mongo</artifactId>
- <version>1.47.3</version>
+ <version>1.48.0</version>
</dependency>
<dependency>
<groupId>junit</groupId>
@@ -348,7 +348,7 @@
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongo-java-driver</artifactId>
- <version>2.13.0</version>
+ <version>3.0.2</version>
</dependency>
<dependency>
<groupId>org.mockito</groupId>
diff --git a/src/main/java/com/syncleus/maven/plugins/mongodb/StartMongoMojo.java b/src/main/java/com/syncleus/maven/plugins/mongodb/StartMongoMojo.java
index f0cbce3e1d75cd4becf00b307472282561459728..28d64a9fe369747109a8b4f7defaedcd5a856ca9 100644
--- a/src/main/java/com/syncleus/maven/plugins/mongodb/StartMongoMojo.java
+++ b/src/main/java/com/syncleus/maven/plugins/mongodb/StartMongoMojo.java
@@ -700,12 +700,7 @@ public class StartMongoMojo extends AbstractMongoMojo {
throw new MojoExecutionException("Database name is missing");
}
- final MongoClient mongoClient;
- try {
- mongoClient = new MongoClient("localhost", getPort());
- } catch (final UnknownHostException e) {
- throw new MojoExecutionException("Unable to connect to mongo instance", e);
- }
+ final MongoClient mongoClient = new MongoClient("localhost", getPort());
getLog().info("Connected to MongoDB");
return mongoClient.getDB(databaseName);
}
diff --git a/src/test/java/com/mongodb/EmbedMongoDB.java b/src/test/java/com/mongodb/EmbedMongoDB.java
index a58f7ea2349aec5add17114d5b26c4d6c6824f7e..37b7e12d2ac77e39ecabea832883bb1eade377f6 100644
--- a/src/test/java/com/mongodb/EmbedMongoDB.java
+++ b/src/test/java/com/mongodb/EmbedMongoDB.java
@@ -16,6 +16,8 @@
*/
package com.mongodb;
+import org.bson.BsonDocument;
+
import java.net.UnknownHostException;
import java.util.Set;
@@ -26,44 +28,20 @@ public class EmbedMongoDB extends DB {
}
public CommandResult notOkErrorResult(String message) {
- try {
- CommandResult commandResult = new CommandResult(new ServerAddress("localhost"));
- commandResult.put("errmsg", message);
- commandResult.put("ok", 0);
- return commandResult;
- } catch (UnknownHostException e) {
- return null;
- }
+ CommandResult commandResult = new CommandResult(new BsonDocument(){}, new ServerAddress("localhost"));
+ commandResult.put("errmsg", message);
+ commandResult.put("ok", 0);
+ return commandResult;
}
@Override
public CommandResult doEval(String code, Object... args) {
- CommandResult commandResult;
- try {
- commandResult = new CommandResult(new ServerAddress("localhost"));
- commandResult.put("ok", 1.0);
- commandResult.put("retval", "null");
- } catch (UnknownHostException e) {
- return notOkErrorResult(e.getMessage());
- }
+ CommandResult commandResult = new CommandResult(new BsonDocument(){}, new ServerAddress("localhost"));
+ commandResult.put("ok", 1.0);
+ commandResult.put("retval", "null");
return commandResult;
}
- @Override
- public void requestStart() {
-
- }
-
- @Override
- public void requestDone() {
-
- }
-
- @Override
- public void requestEnsureConnection() {
-
- }
-
@Override
protected DBCollection doGetCollection(String name) {
return null;
@@ -73,14 +51,4 @@ public class EmbedMongoDB extends DB {
public Set<String> getCollectionNames() {
return null;
}
-
- @Override
- CommandResult doAuthenticate(MongoCredential credentials) {
- return null;
- }
-
- @Override
- public void cleanCursors(boolean force) {
-
- }
}