removed ServerApi
parent
72fee286ec
commit
957dfd2cf5
1
pom.xml
1
pom.xml
|
@ -65,7 +65,6 @@
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.mongodb</groupId>
|
<groupId>org.mongodb</groupId>
|
||||||
<artifactId>mongodb-driver-reactivestreams</artifactId>
|
<artifactId>mongodb-driver-reactivestreams</artifactId>
|
||||||
<scope>compile</scope>
|
|
||||||
<version>4.5.1</version>
|
<version>4.5.1</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
|
@ -2,8 +2,6 @@ package earth.krakatoa.core.mongo;
|
||||||
|
|
||||||
import com.mongodb.ConnectionString;
|
import com.mongodb.ConnectionString;
|
||||||
import com.mongodb.MongoClientSettings;
|
import com.mongodb.MongoClientSettings;
|
||||||
import com.mongodb.ServerApi;
|
|
||||||
import com.mongodb.ServerApiVersion;
|
|
||||||
import com.mongodb.reactivestreams.client.MongoClient;
|
import com.mongodb.reactivestreams.client.MongoClient;
|
||||||
import com.mongodb.reactivestreams.client.MongoClients;
|
import com.mongodb.reactivestreams.client.MongoClients;
|
||||||
import earth.krakatoa.core.config.MongoConfig;
|
import earth.krakatoa.core.config.MongoConfig;
|
||||||
|
@ -14,7 +12,6 @@ public class MongoManager {
|
||||||
|
|
||||||
private ConnectionString connectionString;
|
private ConnectionString connectionString;
|
||||||
|
|
||||||
private ServerApi serverApi;
|
|
||||||
private MongoClientSettings mongoClientSettings;
|
private MongoClientSettings mongoClientSettings;
|
||||||
private MongoClient mongoClient;
|
private MongoClient mongoClient;
|
||||||
|
|
||||||
|
@ -31,10 +28,8 @@ public class MongoManager {
|
||||||
+ mongoConfig.getDatabase()
|
+ mongoConfig.getDatabase()
|
||||||
+ "&readPreference=primary&ssl=false");
|
+ "&readPreference=primary&ssl=false");
|
||||||
|
|
||||||
this.serverApi = ServerApi.builder().version(ServerApiVersion.V1).build();
|
|
||||||
|
|
||||||
this.mongoClientSettings = MongoClientSettings.builder()
|
this.mongoClientSettings = MongoClientSettings.builder()
|
||||||
.applyConnectionString(this.connectionString).serverApi(this.serverApi).build();
|
.applyConnectionString(this.connectionString).build();
|
||||||
|
|
||||||
this.mongoClient = MongoClients.create(this.mongoClientSettings);
|
this.mongoClient = MongoClients.create(this.mongoClientSettings);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue