From 8dfd6191c081a58b25042da5a94361c55da061f1 Mon Sep 17 00:00:00 2001
From: eeff <33566201+eeff@users.noreply.github.com>
Date: Tue, 17 Jan 2023 23:31:46 +0800
Subject: [PATCH] fix(mqtt): create topic mistakes

---
 plugins/mqtt/mqtt_plugin.c | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/plugins/mqtt/mqtt_plugin.c b/plugins/mqtt/mqtt_plugin.c
index a4f8b2a9..f9e3a601 100644
--- a/plugins/mqtt/mqtt_plugin.c
+++ b/plugins/mqtt/mqtt_plugin.c
@@ -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);