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
index a3f115fbb..0bf9045e3 100644
--- 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
index 6f99b5948..189576133 100644
--- 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 | empty | Auth source database use to authenticate the user. Usually could be `admin`. |
| mongo\_replica_set | no | empty | 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. |