From 7d26801d98ba2fb5188c008be70831264564fc82 Mon Sep 17 00:00:00 2001
From: anlicheng <244108715@qq.com>
Date: Wed, 17 Jan 2024 11:57:01 +0800
Subject: [PATCH] fix zd_mqtt_consumer

---
 apps/iot/src/consumer/iot_zd_consumer.erl | 12 ++----------
 1 file changed, 2 insertions(+), 10 deletions(-)

diff --git a/apps/iot/src/consumer/iot_zd_consumer.erl b/apps/iot/src/consumer/iot_zd_consumer.erl
index 581c9a7..8c80109 100644
--- a/apps/iot/src/consumer/iot_zd_consumer.erl
+++ b/apps/iot/src/consumer/iot_zd_consumer.erl
@@ -190,16 +190,8 @@ handle_info(Info, State = #state{}) ->
 %% with Reason. The return value is ignored.
 -spec(terminate(Reason :: (normal | shutdown | {shutdown, term()} | term()),
     State :: #state{}) -> term()).
-terminate(Reason, _State = #state{conn_pid = ConnPid}) when is_pid(ConnPid) ->
-    %% 取消topic的订阅
-    TopicNames = lists:map(fun({Name, _}) -> Name end, ?Topics),
-    {ok, _Props, _ReasonCode} = emqtt:unsubscribe(ConnPid, #{}, TopicNames),
-
-    ok = emqtt:disconnect(ConnPid),
-    lager:debug("[iot_zd_consumer] terminate with reason: ~p", [Reason]),
-    ok;
-terminate(Reason, _State) ->
-    lager:debug("[iot_zd_consumer] terminate with reason: ~p", [Reason]),
+terminate(Reason, State) ->
+    lager:warning("[iot_zd_consumer] terminate with reason: ~p, state: ~p", [Reason, State]),
     ok.
 
 %% @private