update doc

telefonicaid · Jun 18, 2024 · aa3f058 · aa3f058
1 parent 1f33860
commit aa3f058
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 6 deletions.
diff --git a/cygnus-ngsi/src/main/java/com/telefonica/iot/cygnus/sinks/NGSIMongoBaseSink.java b/cygnus-ngsi/src/main/java/com/telefonica/iot/cygnus/sinks/NGSIMongoBaseSink.java
@@ -172,25 +172,25 @@ public void configure(Context context) {
                 + ignoreWhiteSpacesStr + ") -- Must be 'true' or 'false'");
         }  // if else
 
-        String sslEnabledStr = context.getString("sslEnabled", "true");
+        String sslEnabledStr = context.getString("mongo_ssl", "false");
         if (sslEnabledStr.equals("true") || sslEnabledStr.equals("false")) {
             sslEnabled = Boolean.valueOf(sslEnabledStr);
-            LOGGER.debug("[" + this.getName() + "] Reading configuration (sslEnabled="
+            LOGGER.debug("[" + this.getName() + "] Reading configuration (mongo_ssl="
                 + sslEnabledStr + ")");
         }  else {
             invalidConfiguration = true;
-            LOGGER.warn("[" + this.getName() + "] Invalid configuration (sslEnabled="
+            LOGGER.warn("[" + this.getName() + "] Invalid configuration (mongo_ssl="
                 + sslEnabledStr + ") -- Must be 'true' or 'false'");
         }  // if else
 
-        String sslInvalidHostNameAllowedStr = context.getString("sslInvalidHostNameAllowed", "true");
+        String sslInvalidHostNameAllowedStr = context.getString("mongo_ssl_invalid_host_allowed", "false");
         if (sslInvalidHostNameAllowedStr.equals("true") || sslInvalidHostNameAllowedStr.equals("false")) {
             sslInvalidHostNameAllowed = Boolean.valueOf(sslInvalidHostNameAllowedStr);
-            LOGGER.debug("[" + this.getName() + "] Reading configuration (sslInvalidHostNameAllowed="
+            LOGGER.debug("[" + this.getName() + "] Reading configuration (mongo_ssl_invalid_host_allowed="
                 + sslInvalidHostNameAllowedStr + ")");
         }  else {
             invalidConfiguration = true;
-            LOGGER.warn("[" + this.getName() + "] Invalid configuration (sslInvalidHostNameAllowed="
+            LOGGER.warn("[" + this.getName() + "] Invalid configuration (mongo_ssl_invalid_host_allowed="
                 + sslInvalidHostNameAllowedStr + ") -- Must be 'true' or 'false'");
         }  // if else
 

diff --git a/doc/cygnus-ngsi/flume_extensions_catalogue/ngsi_mongo_sink.md b/doc/cygnus-ngsi/flume_extensions_catalogue/ngsi_mongo_sink.md
@@ -320,6 +320,8 @@ When datamodel changes Cygnus tries to recreate index (delete current and create
 | mongo\_auth_source | no | <i>empty</i> | Auth source database use to authenticate the user. Usually could be `admin`. |
 | mongo\_replica_set | no | <i>empty</i> | Replica Set name. Note that this parameter is optional because Cygnus is able to connect to a MongoDB replica set without needing to specify its name.|
 | db\_prefix | no | sth_ ||
+| mongo\_ssl | no | false | Enable SSL in mongodb connection |
+| mongo\_ssl\_invalid\_host\_allowed | no | false | Allow invalid host name in mongo SSL connections |
 | collection\_prefix | no | sth_ | `system.` is not accepted. |
 | batch\_size | no | 1 | Number of events accumulated before persistence. |
 | batch\_timeout | no | 30 | Number of seconds the batch will be building before it is persisted as it is. |