diff --git a/src/emqx_channel.erl b/src/emqx_channel.erl index 65989d9e7..9120e10cb 100644 --- a/src/emqx_channel.erl +++ b/src/emqx_channel.erl @@ -655,7 +655,7 @@ handle_call(Req, Channel) -> handle_cast({register, Attrs, Stats}, #channel{client = #{client_id := ClientId}}) -> ok = emqx_cm:register_channel(ClientId), emqx_cm:set_chan_attrs(ClientId, Attrs), - emqx_cm:set_chan_attrs(ClientId, Stats); + emqx_cm:set_chan_stats(ClientId, Stats); handle_cast(Msg, Channel) -> ?LOG(error, "Unexpected cast: ~p", [Msg]), diff --git a/test/emqx_client_SUITE.erl b/test/emqx_client_SUITE.erl index a00d95603..660892112 100644 --- a/test/emqx_client_SUITE.erl +++ b/test/emqx_client_SUITE.erl @@ -100,7 +100,7 @@ t_cm(_) -> emqtt:subscribe(C, <<"mytopic">>, 0), ct:sleep(1200), Stats = emqx_cm:get_chan_stats(ClientId), - ?assertEqual(1, proplists:get_value(subscriptions, Stats)), + ?assertEqual(1, proplists:get_value(subscriptions_cnt, Stats)), emqx_zone:set_env(external, idle_timeout, IdleTimeout). t_cm_registry(_) ->