[
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)
