yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

chore(willmsg): remove unreachable code

This commit is contained in:
William Yang 2024-02-26 17:59:05 +01:00
parent d5247cb567
commit 88fc67b369
1 changed files with 0 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
apps/emqx/src/emqx_channel.erl
View File

@ -2353,22 +2353,6 @@ maybe_publish_will_msg(
end, end,
%% Maybe we should cancel first then send %% Maybe we should cancel first then send
remove_willmsg(Channel); remove_willmsg(Channel);
maybe_publish_will_msg(
{shutdown, _},
Channel = #channel{
conninfo = #{expiry_interval := 0, clientid := ClientId},
clientinfo = ClientInfo,
will_msg = WillMsg
}
) ->
%% MQTT 5: 3.1.2.11.2 Session Expiry Interval
%% If the Session Expiry Interval is absent the value 0 is used.
%% If it is set to 0, or is absent, the Session ends when the Network Connection is closed.
%% Expire_interval == 0, means session is end at the time of calling with shutdown.
?tp(debug, maybe_publish_will_msg_shutdown, #{clientid => ClientId}),
_ = publish_will_msg(ClientInfo, WillMsg),
%% Maybe we should cancel first then send
remove_willmsg(Channel);
maybe_publish_will_msg( maybe_publish_will_msg(
Reason, Reason,
Channel = #channel{ Channel = #channel{