anlicheng/iot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
anlicheng 2023-06-20 18:01:12 +08:00
parent db09dc81b7
commit f0f7873041
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
apps/iot/src/iot_mqtt_reply_subscriber.erl
View File

@ -150,8 +150,7 @@ handle_info(Info, State = #state{}) ->
State :: #state{}) -> term()). State :: #state{}) -> term()).
terminate(Reason, _State = #state{conn_pid = ConnPid}) when is_pid(ConnPid) -> terminate(Reason, _State = #state{conn_pid = ConnPid}) when is_pid(ConnPid) ->
%% 取消topic的订阅 %% 取消topic的订阅
TopicNames = lists:map(fun({Name, _}) -> Name end, ?Topics), {ok, _Props, _ReasonCode} = emqtt:unsubscribe(ConnPid, #{}, ?Topic),
{ok, _Props, _ReasonCode} = emqtt:unsubscribe(ConnPid, #{}, TopicNames),
ok = emqtt:disconnect(ConnPid), ok = emqtt:disconnect(ConnPid),
lager:debug("[iot_mqtt_reply_subscriber] terminate with reason: ~p", [Reason]), lager:debug("[iot_mqtt_reply_subscriber] terminate with reason: ~p", [Reason]),