From fba83e6519b4bb8938e591d47e766871970aaa20 Mon Sep 17 00:00:00 2001 From: fengzero Date: Mon, 16 Jun 2025 02:39:03 +0000 Subject: [PATCH] fix cppcheck --- plugins/mqtt/azure_iot_plugin.c | 1 + plugins/mqtt/mqtt_plugin_intf.c | 4 +--- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/plugins/mqtt/azure_iot_plugin.c b/plugins/mqtt/azure_iot_plugin.c index c5caa55a..0c7c5a43 100644 --- a/plugins/mqtt/azure_iot_plugin.c +++ b/plugins/mqtt/azure_iot_plugin.c @@ -184,6 +184,7 @@ static int azure_parse_config(neu_plugin_t *plugin, const char *setting, config->cert = cert.v.val_str; config->key = key.v.val_str; config->upload_drv_state = false; + config->enable_topic = true; plog_notice(plugin, "config MQTT version : %d", config->version); plog_notice(plugin, "config client-id : %s", config->client_id); diff --git a/plugins/mqtt/mqtt_plugin_intf.c b/plugins/mqtt/mqtt_plugin_intf.c index 6ed6a920..00e36e49 100644 --- a/plugins/mqtt/mqtt_plugin_intf.c +++ b/plugins/mqtt/mqtt_plugin_intf.c @@ -395,9 +395,7 @@ int mqtt_plugin_config(neu_plugin_t *plugin, const char *setting) } if (plugin->client != NULL) { - if (neu_mqtt_client_is_open(plugin->client)) { - rv = neu_mqtt_client_close(plugin->client); - } + neu_mqtt_client_close(plugin->client); neu_mqtt_client_free(plugin->client); } plugin->client = neu_mqtt_client_new(config.version);