From 1c61165a9185661127820e40c2bc3e8f31fc9843 Mon Sep 17 00:00:00 2001 From: Ilya Averyanov Date: Thu, 16 Feb 2023 17:38:54 +0300 Subject: [PATCH] fix(ft): fix emqx_cm takover --- apps/emqx/src/emqx_cm.erl | 1 + 1 file changed, 1 insertion(+) diff --git a/apps/emqx/src/emqx_cm.erl b/apps/emqx/src/emqx_cm.erl index 766acd4b8..90b279fa4 100644 --- a/apps/emqx/src/emqx_cm.erl +++ b/apps/emqx/src/emqx_cm.erl @@ -312,6 +312,7 @@ open_session(false, ClientInfo = #{clientid := ClientId}, ConnInfo) -> Session1 = emqx_persistent_session:persist( ClientInfo, ConnInfo, Session ), + register_channel(ClientId, Self, ConnInfo), {ok, #{ session => clean_session(Session1), present => true,