diff --git a/apps/emqtt/src/emqtt_protocol.erl b/apps/emqtt/src/emqtt_protocol.erl index 2bc27b39c..0e108da8f 100644 --- a/apps/emqtt/src/emqtt_protocol.erl +++ b/apps/emqtt/src/emqtt_protocol.erl @@ -359,5 +359,5 @@ send_will_msg(#proto_state{will_msg = WillMsg }) -> start_keepalive(0) -> ignore; start_keepalive(Sec) when Sec > 0 -> - self() ! {keepalive, start, Sec * 1.5}. + self() ! {keepalive, start, round(Sec * 1.5)}.