fix(ft): fix emqx_cm takover
This commit is contained in:
parent
c6b3f2c2ca
commit
1c61165a91
|
@ -312,6 +312,7 @@ open_session(false, ClientInfo = #{clientid := ClientId}, ConnInfo) ->
|
||||||
Session1 = emqx_persistent_session:persist(
|
Session1 = emqx_persistent_session:persist(
|
||||||
ClientInfo, ConnInfo, Session
|
ClientInfo, ConnInfo, Session
|
||||||
),
|
),
|
||||||
|
register_channel(ClientId, Self, ConnInfo),
|
||||||
{ok, #{
|
{ok, #{
|
||||||
session => clean_session(Session1),
|
session => clean_session(Session1),
|
||||||
present => true,
|
present => true,
|
||||||
|
|
Loading…
Reference in New Issue