yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(retainer): trap exit message

This commit is contained in:
lafirest 2022-03-02 17:06:48 +08:00
parent 123b667eb0
commit 4a9ba7f8b8
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx_retainer/src/emqx_retainer.erl
View File

@ -156,6 +156,7 @@ stats_fun() ->
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
init([]) -> init([]) ->
erlang:process_flag(trap_exit, true),
emqx_conf:add_handler([retainer], ?MODULE), emqx_conf:add_handler([retainer], ?MODULE),
State = new_state(), State = new_state(),
#{enable := Enable} = Cfg = emqx:get_config([retainer]), #{enable := Enable} = Cfg = emqx:get_config([retainer]),
@ -209,6 +210,7 @@ handle_info(Info, State) ->
{noreply, State}. {noreply, State}.
terminate(_Reason, #{clear_timer := ClearTimer}) -> terminate(_Reason, #{clear_timer := ClearTimer}) ->
emqx_conf:remove_handler([retainer]),
_ = stop_timer(ClearTimer), _ = stop_timer(ClearTimer),
ok. ok.