From b8712ecf82c17f4871173a0bd4d9ee94bdfb75bc Mon Sep 17 00:00:00 2001 From: Alvaro Vega Date: Thu, 1 Aug 2024 08:36:32 +0200 Subject: [PATCH] Update MongoBackendImpl.java --- .../iot/cygnus/backends/mongo/MongoBackendImpl.java | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) 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 index d324e6b7a..d4021859d 100644 --- 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