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

fix(emqx_session_mem): keep msg inflight insert timestamp in Inflight after retry

This commit is contained in:
Serge Tupchii 2024-03-27 11:31:51 +02:00
parent ae5b511c83
commit a3b730ff10
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/emqx/src/emqx_session_mem.erl
View File

@ -637,10 +637,10 @@ do_retry_delivery(
_ = emqx_session_events:handle_event(ClientInfo, {expired, Msg}),
{Acc, emqx_inflight:delete(PacketId, Inflight)};
false ->
Msg1 = without_inflight_insert_ts(emqx_message:set_flag(dup, true, Msg)),
Msg1 = emqx_message:set_flag(dup, true, Msg),
Update = Data#inflight_data{message = Msg1, timestamp = Now},
Inflight1 = emqx_inflight:update(PacketId, Update, Inflight),
{[{PacketId, Msg1} | Acc], Inflight1}
{[{PacketId, without_inflight_insert_ts(Msg1)} | Acc], Inflight1}
end;
do_retry_delivery(_ClientInfo, PacketId, Data, Now, Acc, Inflight) ->
Update = Data#inflight_data{timestamp = Now},