From 675edf3fab850c99c87123a1b8a970d8f06aea30 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=91=A8=E5=AD=90=E5=8D=9A?= <349832309@qq.com> Date: Tue, 18 Dec 2018 12:01:41 +0800 Subject: [PATCH] Fix a bug that will not send a will message in some cases --- src/emqx_session.erl | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/emqx_session.erl b/src/emqx_session.erl index 12718b9fc..cb1d04780 100644 --- a/src/emqx_session.erl +++ b/src/emqx_session.erl @@ -963,7 +963,8 @@ ensure_expire_timer(State) -> ensure_will_delay_timer(State = #state{will_msg = #message{headers = #{'Will-Delay-Interval' := WillDelayInterval}}}) -> State#state{will_delay_timer = emqx_misc:start_timer(WillDelayInterval * 1000, will_delay)}; -ensure_will_delay_timer(State) -> +ensure_will_delay_timer(State = #state{will_msg = WillMsg}) -> + send_willmsg(WillMsg), State. ensure_stats_timer(State = #state{enable_stats = true, stats_timer = undefined,