From ad3a7939102b6822d2f324ce694916034ef1725b Mon Sep 17 00:00:00 2001 From: "Zaiming (Stone) Shi" Date: Mon, 19 Dec 2022 20:12:38 +0100 Subject: [PATCH] fix(shared_sub): insert alive pid table at mnesia table event --- apps/emqx/src/emqx_shared_sub.erl | 1 + 1 file changed, 1 insertion(+) diff --git a/apps/emqx/src/emqx_shared_sub.erl b/apps/emqx/src/emqx_shared_sub.erl index 051ba7b11..556347f89 100644 --- a/apps/emqx/src/emqx_shared_sub.erl +++ b/apps/emqx/src/emqx_shared_sub.erl @@ -446,6 +446,7 @@ handle_info( {mnesia_table_event, {write, #emqx_shared_subscription{subpid = SubPid}, _}}, State = #state{pmon = PMon} ) -> + ok = maybe_insert_alive_tab(SubPid), {noreply, update_stats(State#state{pmon = emqx_pmon:monitor(SubPid, PMon)})}; %% The subscriber may have subscribed multiple topics, so we need to keep monitoring the PID until %% it `unsubscribed` the last topic.