Github user minifirocks commented on a diff in the pull request:
https://github.com/apache/nifi-minifi-cpp/pull/259#discussion_r166072113
--- Diff: extensions/mqtt/AbstractMQTTProcessor.cpp ---
@@ -119,6 +126,38 @@ void
AbstractMQTTProcessor::onSchedule(core::ProcessContext *context, core::Proc
qos_ = valInt;
logger_->log_debug("AbstractMQTTProcessor: QOS [%ll]", qos_);
}
+ value = "";
+
+ if (context->getProperty(SecurityProtocol.getName(), value) &&
!value.empty()) {
+ if (value == MQTT_SECURITY_PROTOCOL_SSL) {
+ sslEnabled_ = true;
--- End diff --
the SSL handshake will fail and based on the error, user need to config the
right certs.
---
