[ https://issues.apache.org/jira/browse/MINIFICPP-393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16352572#comment-16352572 ]
ASF GitHub Bot commented on MINIFICPP-393: ------------------------------------------ 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? > add security support for MQTT > ----------------------------- > > Key: MINIFICPP-393 > URL: https://issues.apache.org/jira/browse/MINIFICPP-393 > Project: NiFi MiNiFi C++ > Issue Type: Improvement > Affects Versions: 1.0.0 > Reporter: bqiu > Assignee: bqiu > Priority: Minor > Fix For: 1.0.0 > > > add security support for MQTT -- This message was sent by Atlassian JIRA (v7.6.3#76005)