Browse Source

Polishing.

Align ConnectionString defaulting. Fix broken Javadoc links.

See: #3932
Original pull request: #5034
pull/5039/head
Mark Paluch 4 months ago
parent
commit
bbefb0b373
No known key found for this signature in database
GPG Key ID: 55BC6374BAA9D973
  1. 9
      spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/MongoClientFactoryBean.java
  2. 4
      spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/MongoClientSettingsFactoryBean.java

9
spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/MongoClientFactoryBean.java

@ -291,7 +291,8 @@ public class MongoClientFactoryBean extends AbstractFactoryBean<MongoClient> imp
applySettings(builder::retryWrites, computeSettingsValue(defaultSettings.getRetryWrites(), applySettings(builder::retryWrites, computeSettingsValue(defaultSettings.getRetryWrites(),
mongoClientSettings.getRetryWrites(), connectionString.getRetryWritesValue())); mongoClientSettings.getRetryWrites(), connectionString.getRetryWritesValue()));
applySettings(builder::uuidRepresentation, applySettings(builder::uuidRepresentation,
computeSettingsValue(null, mongoClientSettings.getUuidRepresentation(), UuidRepresentation.STANDARD)); computeSettingsValue(null, mongoClientSettings.getUuidRepresentation(),
connectionString.getUuidRepresentation()));
} }
if (!CollectionUtils.isEmpty(credential)) { if (!CollectionUtils.isEmpty(credential)) {
@ -315,13 +316,15 @@ public class MongoClientFactoryBean extends AbstractFactoryBean<MongoClient> imp
settingsBuilder.accept(value); settingsBuilder.accept(value);
} }
private <S, T> @Nullable T computeSettingsValue(Function<S, T> function, S defaultValueHolder, S settingsValueHolder, private <S extends @Nullable Object, T extends @Nullable Object> @Nullable T computeSettingsValue(
Function<S, T> function, S defaultValueHolder, S settingsValueHolder,
@Nullable T connectionStringValue) { @Nullable T connectionStringValue) {
return computeSettingsValue(function.apply(defaultValueHolder), function.apply(settingsValueHolder), return computeSettingsValue(function.apply(defaultValueHolder), function.apply(settingsValueHolder),
connectionStringValue); connectionStringValue);
} }
private <T> @Nullable T computeSettingsValue(@Nullable T defaultValue, T fromSettings, @Nullable T fromConnectionString) { private <T extends @Nullable Object> @Nullable T computeSettingsValue(@Nullable T defaultValue,
@Nullable T fromSettings, @Nullable T fromConnectionString) {
boolean fromSettingsIsDefault = ObjectUtils.nullSafeEquals(defaultValue, fromSettings); boolean fromSettingsIsDefault = ObjectUtils.nullSafeEquals(defaultValue, fromSettings);
boolean fromConnectionStringIsDefault = ObjectUtils.nullSafeEquals(defaultValue, fromConnectionString); boolean fromConnectionStringIsDefault = ObjectUtils.nullSafeEquals(defaultValue, fromConnectionString);

4
spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/MongoClientSettingsFactoryBean.java

@ -119,7 +119,7 @@ public class MongoClientSettingsFactoryBean extends AbstractFactoryBean<MongoCli
/** /**
* @param socketConnectTimeoutMS in msec * @param socketConnectTimeoutMS in msec
* @see com.mongodb.connection.SocketSettings.Builder#connectTimeout(int, TimeUnit) * @see com.mongodb.connection.SocketSettings.Builder#connectTimeout(long, TimeUnit)
*/ */
public void setSocketConnectTimeoutMS(int socketConnectTimeoutMS) { public void setSocketConnectTimeoutMS(int socketConnectTimeoutMS) {
this.socketConnectTimeoutMS = socketConnectTimeoutMS; this.socketConnectTimeoutMS = socketConnectTimeoutMS;
@ -127,7 +127,7 @@ public class MongoClientSettingsFactoryBean extends AbstractFactoryBean<MongoCli
/** /**
* @param socketReadTimeoutMS in msec * @param socketReadTimeoutMS in msec
* @see com.mongodb.connection.SocketSettings.Builder#readTimeout(int, TimeUnit) * @see com.mongodb.connection.SocketSettings.Builder#readTimeout(long, TimeUnit)
*/ */
public void setSocketReadTimeoutMS(int socketReadTimeoutMS) { public void setSocketReadTimeoutMS(int socketReadTimeoutMS) {
this.socketReadTimeoutMS = socketReadTimeoutMS; this.socketReadTimeoutMS = socketReadTimeoutMS;

Loading…
Cancel
Save