diff --git a/pom.xml b/pom.xml index badb703..33f91de 100755 --- a/pom.xml +++ b/pom.xml @@ -65,7 +65,6 @@ org.mongodb mongodb-driver-reactivestreams - compile 4.5.1 diff --git a/src/main/java/earth/krakatoa/core/mongo/MongoManager.java b/src/main/java/earth/krakatoa/core/mongo/MongoManager.java index 7010505..30c99bb 100755 --- a/src/main/java/earth/krakatoa/core/mongo/MongoManager.java +++ b/src/main/java/earth/krakatoa/core/mongo/MongoManager.java @@ -2,8 +2,6 @@ package earth.krakatoa.core.mongo; import com.mongodb.ConnectionString; import com.mongodb.MongoClientSettings; -import com.mongodb.ServerApi; -import com.mongodb.ServerApiVersion; import com.mongodb.reactivestreams.client.MongoClient; import com.mongodb.reactivestreams.client.MongoClients; import earth.krakatoa.core.config.MongoConfig; @@ -14,7 +12,6 @@ public class MongoManager { private ConnectionString connectionString; - private ServerApi serverApi; private MongoClientSettings mongoClientSettings; private MongoClient mongoClient; @@ -31,10 +28,8 @@ public class MongoManager { + mongoConfig.getDatabase() + "&readPreference=primary&ssl=false"); - this.serverApi = ServerApi.builder().version(ServerApiVersion.V1).build(); - this.mongoClientSettings = MongoClientSettings.builder() - .applyConnectionString(this.connectionString).serverApi(this.serverApi).build(); + .applyConnectionString(this.connectionString).build(); this.mongoClient = MongoClients.create(this.mongoClientSettings); }