GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-17 04:40:42 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(mqtt): create topic mistakes

Browse Source
This commit is contained in:
eeff
2023-01-17 23:31:46 +08:00
parent b7aecf74d3
commit 8dfd6191c0
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/mqtt/mqtt_plugin.c
+2 -2
View File
@@ -239,7 +239,7 @@ static int create_topic(neu_plugin_t *plugin)
neu_asprintf(&plugin->write_req_topic, "/neuron/%s/write/req",
plugin->common.name);
if (NULL == plugin->read_req_topic) {
if (NULL == plugin->write_req_topic) {
free(plugin->read_req_topic);
plugin->read_req_topic = NULL;
free(plugin->read_resp_topic);
@@ -249,7 +249,7 @@ static int create_topic(neu_plugin_t *plugin)
neu_asprintf(&plugin->write_resp_topic, "/neuron/%s/write/resp",
plugin->common.name);
if (NULL == plugin->read_req_topic) {
if (NULL == plugin->write_resp_topic) {
free(plugin->read_req_topic);
plugin->read_req_topic = NULL;
free(plugin->read_resp_topic);