@@ -509,7 +509,6 @@ public ConnectionString(final String connectionString, @Nullable final DnsClient
509
509
510
510
credential = createCredentials (combinedOptionsMaps , userName , password );
511
511
warnOnUnsupportedOptions (combinedOptionsMaps );
512
- warnDeprecatedTimeouts (combinedOptionsMaps );
513
512
}
514
513
515
514
private static final Set <String > GENERAL_OPTIONS_KEYS = new LinkedHashSet <>();
@@ -518,7 +517,6 @@ public ConnectionString(final String connectionString, @Nullable final DnsClient
518
517
private static final Set <String > WRITE_CONCERN_KEYS = new HashSet <>();
519
518
private static final Set <String > COMPRESSOR_KEYS = new HashSet <>();
520
519
private static final Set <String > ALL_KEYS = new HashSet <>();
521
- private static final Set <String > DEPRECATED_TIMEOUT_KEYS = new HashSet <>();
522
520
523
521
static {
524
522
GENERAL_OPTIONS_KEYS .add ("minpoolsize" );
@@ -592,10 +590,6 @@ public ConnectionString(final String connectionString, @Nullable final DnsClient
592
590
ALL_KEYS .addAll (READ_PREFERENCE_KEYS );
593
591
ALL_KEYS .addAll (WRITE_CONCERN_KEYS );
594
592
ALL_KEYS .addAll (COMPRESSOR_KEYS );
595
-
596
- DEPRECATED_TIMEOUT_KEYS .add ("sockettimeoutms" );
597
- DEPRECATED_TIMEOUT_KEYS .add ("waitqueuetimeoutms" );
598
- DEPRECATED_TIMEOUT_KEYS .add ("wtimeoutms" );
599
593
}
600
594
601
595
// Any options contained in the connection string completely replace the corresponding options specified in TXT records,
@@ -616,15 +610,6 @@ private void warnOnUnsupportedOptions(final Map<String, List<String>> optionsMap
616
610
.forEach (k -> LOGGER .warn (format ("Connection string contains unsupported option '%s'." , k )));
617
611
}
618
612
}
619
- private void warnDeprecatedTimeouts (final Map <String , List <String >> optionsMap ) {
620
- if (LOGGER .isWarnEnabled ()) {
621
- optionsMap .keySet ()
622
- .stream ()
623
- .filter (DEPRECATED_TIMEOUT_KEYS ::contains )
624
- .forEach (k -> LOGGER .warn (format ("Use of deprecated timeout option: '%s'. Prefer 'timeoutMS' instead." , k )));
625
- }
626
- }
627
-
628
613
629
614
private void translateOptions (final Map <String , List <String >> optionsMap ) {
630
615
boolean tlsInsecureSet = false ;
0 commit comments