diff --git a/src/emqx_message.erl b/src/emqx_message.erl index 9ff8e7511..311bd58dd 100644 --- a/src/emqx_message.erl +++ b/src/emqx_message.erl @@ -120,7 +120,9 @@ update_expiry(Msg = #message{headers = #{'Message-Expiry-Interval' := Interval}, Elapsed when Elapsed > 0 -> set_header('Message-Expiry-Interval', max(1, Interval - (Elapsed div 1000)), Msg); _ -> Msg - end. + end; + +update_expiry(Msg) -> Msg. %% MilliSeconds elapsed(Since) ->