Github user phrocker commented on a diff in the pull request:
https://github.com/apache/nifi-minifi-cpp/pull/259#discussion_r166013537
--- 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 --
what happens if a cert isn't specified or the CA isn't specified but needs
to be?
---
