Merge pull request #2395 from telefonicaid/task/allow_mongo_autodisco…

…ver_when_only_one_server_provided Allow mongodb autodiscover at connect when just one server is provided
telefonicaid · Aug 1, 2024 · 7764af1 · 7764af1
2 parents e7be92d + 7e2201b
commit 7764af1
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 2 deletions.
diff --git a/CHANGES_NEXT_RELEASE b/CHANGES_NEXT_RELEASE
@@ -1,2 +1,3 @@
 [cygnus-ngsi] [mongo-sink] Add mongo_ssl, mongo_ssl_invalid_host_allowed, mongo_ssl_keystore_path_file, mongo_ssl_keystore_password, mongo_ssl_truststore_path_file and mongo_ssl_truststore_password options for mongoDB connections
 [cygnus-common] [mongo-backend] Use sslEnabled, sslInvalidHostNameAllowed, sslKeystorePathFile, sslKeystorePassword, sslTruststorePathFile and sslTruststorePassword options for mongoDB connections
+[cygnus-common] [mongo-backend] Allow mongodb autodiscover at connect when just one server is provided
diff --git a/cygnus-common/src/main/java/com/telefonica/iot/cygnus/backends/mongo/MongoBackendImpl.java b/cygnus-common/src/main/java/com/telefonica/iot/cygnus/backends/mongo/MongoBackendImpl.java
@@ -661,9 +661,17 @@ private MongoDatabase getDatabase(String dbName) {
                         .sslContext(sslContext)
                         .build();
                 }
-                client = new MongoClient(servers, credential, options);
+                if (servers.size() == 1) { // allow auto-discover when just one endpoint is provided
+                    client = new MongoClient(servers.get(0), credential, options);
+                } else {
+                    client = new MongoClient(servers, credential, options);
+                }
             } else {
-                client = new MongoClient(servers, options);
+                if (servers.size() == 1) { // allow auto-discover when just one endpoint is provided
+                    client = new MongoClient(servers.get(0), options);
+                } else {
+                    client = new MongoClient(servers, options);
+                }
             } // if else
         } // if