From e9ce8e7586143175590e5805c6c30ec15e04270b Mon Sep 17 00:00:00 2001 From: firest Date: Fri, 12 Nov 2021 18:31:55 +0800 Subject: [PATCH] fix(emqx_retainer): revert the "refresh the timestamp when dispatch retained message" This reverts commit 66d0c44e3612a3446970b121f30efbac57b78abe. --- apps/emqx_retainer/src/emqx_retainer.erl | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/apps/emqx_retainer/src/emqx_retainer.erl b/apps/emqx_retainer/src/emqx_retainer.erl index 8884731f3..340e6929d 100644 --- a/apps/emqx_retainer/src/emqx_retainer.erl +++ b/apps/emqx_retainer/src/emqx_retainer.erl @@ -78,8 +78,7 @@ dispatch(Pid, Topic) -> false -> read_messages(Topic); true -> match_messages(Topic) end, - Now = erlang:system_time(millisecond), - [Pid ! {deliver, Topic, Msg#message{timestamp = Now}} || Msg <- sort_retained(Msgs)]. + [Pid ! {deliver, Topic, Msg} || Msg <- sort_retained(Msgs)]. %% RETAIN flag set to 1 and payload containing zero bytes on_message_publish(Msg = #message{flags = #{retain := true},