From 252514bfe0558c65d8ae1d16ff9b69f804a65502 Mon Sep 17 00:00:00 2001 From: lafirest Date: Tue, 8 Feb 2022 18:28:00 +0800 Subject: [PATCH] fix(emqx_slow_subs): trap the exit message --- apps/emqx_plugin_libs/src/emqx_slow_subs/emqx_slow_subs.erl | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/apps/emqx_plugin_libs/src/emqx_slow_subs/emqx_slow_subs.erl b/apps/emqx_plugin_libs/src/emqx_slow_subs/emqx_slow_subs.erl index f276d7ba0..f047b7f5b 100644 --- a/apps/emqx_plugin_libs/src/emqx_slow_subs/emqx_slow_subs.erl +++ b/apps/emqx_plugin_libs/src/emqx_slow_subs/emqx_slow_subs.erl @@ -133,6 +133,7 @@ init_tab() -> %%-------------------------------------------------------------------- init([Conf]) -> + erlang:process_flag(trap_exit, true), expire_tick(Conf), load(Conf), {ok, #{config => Conf, @@ -201,7 +202,7 @@ load(Cfg) -> ok. unload() -> - emqx:unhook('delivery.completed', fun ?MODULE:on_delivery_completed/4 ), + emqx:unhook('delivery.completed', fun ?MODULE:on_delivery_completed/4), do_clear_history(). do_clear(Cfg, Logs) ->