diff --git a/apps/emqtt/src/emqtt_sm.erl b/apps/emqtt/src/emqtt_sm.erl index f98dc27d3..439ce3a30 100644 --- a/apps/emqtt/src/emqtt_sm.erl +++ b/apps/emqtt/src/emqtt_sm.erl @@ -134,7 +134,7 @@ handle_call({destroy_session, ClientId}, _From, State) -> case ets:lookup(?TABLE, ClientId) of [{_, SessPid, MRef}] -> erlang:demonitor(MRef), - emqtt_session:destory(SessPid, ClientId), + emqtt_session:destroy(SessPid, ClientId), ets:delete(?TABLE, ClientId); [] -> ignore