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

fix(emqx_retainer): revert the "refresh the timestamp when dispatch retained message" 

This reverts commit 66d0c44e36.
This commit is contained in:
firest 2021-11-12 18:31:55 +08:00
parent f3de1bdb77
commit e9ce8e7586
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
apps/emqx_retainer/src/emqx_retainer.erl
View File

@ -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},