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