From a3b730ff10e0e392c06233a2a4ff677a97502c39 Mon Sep 17 00:00:00 2001 From: Serge Tupchii Date: Wed, 27 Mar 2024 11:31:51 +0200 Subject: [PATCH] fix(emqx_session_mem): keep msg inflight insert timestamp in Inflight after retry --- apps/emqx/src/emqx_session_mem.erl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/apps/emqx/src/emqx_session_mem.erl b/apps/emqx/src/emqx_session_mem.erl index 2e12d330c..df3d43fb4 100644 --- a/apps/emqx/src/emqx_session_mem.erl +++ b/apps/emqx/src/emqx_session_mem.erl @@ -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},