From 27dc5233cda9a1378c132008921e4df60cccab34 Mon Sep 17 00:00:00 2001 From: William Yang Date: Fri, 17 Nov 2023 17:55:38 +0100 Subject: [PATCH] fix(reconnect): puback error --- src/emqtt.erl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/emqtt.erl b/src/emqtt.erl index b41afbb0..ae48931f 100644 --- a/src/emqtt.erl +++ b/src/emqtt.erl @@ -1448,7 +1448,7 @@ handle_event(info, {Closed, Sock}, StateName, State) {stop, {shutdown, Closed}, State}; handle_event(info, {'EXIT', Owner, Reason}, _, State = #state{owner = Owner}) -> - ?LOG(debug, "EXIT_from_owner", #{reason => Reason}, State), + ?LOG(error, "EXIT_from_owner", #{reason => Reason}, State), {stop, {shutdown, {owner, Owner, Reason}}, State}; handle_event(info, {inet_reply, _Sock, ok}, _, _State) -> @@ -1970,7 +1970,7 @@ host(Host) -> Host. send_puback(Via, Packet, State) -> case send(Via, Packet, State) of {ok, NewState} -> {keep_state, NewState}; - {error, Reason} -> {stop, {shutdown, Reason}} + {error, Reason} -> maybe_shutdown(Reason, State) end. send(Msg, State) ->