From 710302f377e07056fad0d2330fb11dd87197e483 Mon Sep 17 00:00:00 2001 From: Feng Lee Date: Fri, 23 Aug 2019 14:52:11 +0800 Subject: [PATCH] Fix case clause error --- src/emqx_channel.erl | 3 --- src/emqx_cm.erl | 2 +- 2 files changed, 1 insertion(+), 4 deletions(-) diff --git a/src/emqx_channel.erl b/src/emqx_channel.erl index c11b1e651..e1a38e43e 100644 --- a/src/emqx_channel.erl +++ b/src/emqx_channel.erl @@ -610,9 +610,6 @@ handle_call(Req, Channel) -> %% Handle cast %%-------------------------------------------------------------------- -handle_cast(discard, Channel) -> - {stop, {shutdown, discarded}, Channel}; - handle_cast(Msg, Channel) -> ?LOG(error, "Unexpected cast: ~p", [Msg]), {ok, Channel}. diff --git a/src/emqx_cm.erl b/src/emqx_cm.erl index 9c3b58068..3673085ac 100644 --- a/src/emqx_cm.erl +++ b/src/emqx_cm.erl @@ -233,7 +233,7 @@ discard_session(ClientId) when is_binary(ClientId) -> discard_session(ClientId, ChanPid) when node(ChanPid) == node() -> case get_chan_attrs(ClientId, ChanPid) of - #{conn_mod := ConnMod} -> + #{client := #{conn_mod := ConnMod}} -> ConnMod:discard(ChanPid); undefined -> ok end;