parent
b97892ff88
commit
4d031999ce
|
|
@ -83,7 +83,7 @@ public class ReactiveMongoClientFactory {
|
|||
Builder builder = builder(settings);
|
||||
String host = (this.properties.getHost() != null) ? this.properties.getHost()
|
||||
: "localhost";
|
||||
builder.applyToClusterSettings(cluster -> cluster
|
||||
builder.applyToClusterSettings((cluster) -> cluster
|
||||
.hosts(Collections.singletonList(new ServerAddress(host, port))));
|
||||
return createMongoClient(builder);
|
||||
}
|
||||
|
|
@ -108,7 +108,7 @@ public class ReactiveMongoClientFactory {
|
|||
int port = getOrDefault(this.properties.getPort(), MongoProperties.DEFAULT_PORT);
|
||||
ServerAddress serverAddress = new ServerAddress(host, port);
|
||||
builder.applyToClusterSettings(
|
||||
cluster -> cluster.hosts(Collections.singletonList(serverAddress)));
|
||||
(cluster) -> cluster.hosts(Collections.singletonList(serverAddress)));
|
||||
return createMongoClient(builder);
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -121,7 +121,7 @@ public class MongoReactiveAutoConfigurationTests {
|
|||
public MongoClientSettings mongoClientSettings() {
|
||||
return MongoClientSettings.builder().readPreference(ReadPreference.nearest())
|
||||
.applyToSocketSettings(
|
||||
socket -> socket.readTimeout(300, TimeUnit.SECONDS))
|
||||
(socket) -> socket.readTimeout(300, TimeUnit.SECONDS))
|
||||
.build();
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@ package org.springframework.boot.autoconfigure.mongo;
|
|||
import java.util.Arrays;
|
||||
import java.util.List;
|
||||
|
||||
import com.mongodb.MongoClientSettings;
|
||||
import com.mongodb.MongoCredential;
|
||||
import com.mongodb.ServerAddress;
|
||||
import com.mongodb.MongoClientSettings;
|
||||
import com.mongodb.connection.ClusterSettings;
|
||||
import com.mongodb.reactivestreams.client.MongoClient;
|
||||
import org.junit.Rule;
|
||||
|
|
|
|||
Loading…
Reference in New Issue