mirror of
https://github.com/emqx/neuron.git
synced 2026-10-22 09:23:52 +08:00
@@ -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);
|
||||
|
||||
@@ -342,7 +342,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);
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user