From db1cf4469b0cc95c6d7fe5011db1ee4181ccbf2a Mon Sep 17 00:00:00 2001 From: zhouzb Date: Fri, 20 Sep 2019 20:27:08 +0800 Subject: [PATCH] Fix crash --- src/emqx_cm.erl | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/emqx_cm.erl b/src/emqx_cm.erl index 56fe3c109..4da131269 100644 --- a/src/emqx_cm.erl +++ b/src/emqx_cm.erl @@ -239,7 +239,7 @@ discard_session(ClientId) when is_binary(ClientId) -> discard_session(ClientId, ChanPid) when node(ChanPid) == node() -> case get_chan_attrs(ClientId, ChanPid) of - #{client := #{conn_mod := ConnMod}} -> + #{conninfo := #{conn_mod := ConnMod}} -> ConnMod:call(ChanPid, discard); undefined -> ok end;