Merge pull request #3 from emqtt/emqx30

Fix update_expiry/1 function_clause
2018-08-30 19:03:52 +08:00 · 2018-08-30 19:03:52 +08:00 · 01d85ad42f
parent 8b0f876412 cae673cf5e
commit 01d85ad42f
1 changed files with 3 additions and 1 deletions
--- 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) ->