diff --git a/src/emqx.appup.src b/src/emqx.appup.src index 8c778ef36..53e77a103 100644 --- a/src/emqx.appup.src +++ b/src/emqx.appup.src @@ -2,9 +2,12 @@ {VSN, [ {"4.3.3", - [{load_module,emqx_packet,brutal_purge,soft_purge,[]}]}, + [{load_module,emqx_packet,brutal_purge,soft_purge,[]}, + {load_module,emqx_ws_connection,brutal_purge,soft_purge,[]} + ]}, {"4.3.2", [{load_module,emqx_packet,brutal_purge,soft_purge,[]}, + {load_module,emqx_ws_connection,brutal_purge,soft_purge,[]}, {load_module,emqx_http_lib,brutal_purge,soft_purge,[]}, {load_module,emqx_channel,brutal_purge,soft_purge,[]}, {load_module,emqx_app,brutal_purge,soft_purge,[]}, @@ -41,9 +44,12 @@ {load_module,emqx_http_lib,brutal_purge,soft_purge,[]}]}, {<<".*">>,[]}], [{"4.3.3", - [{load_module,emqx_packet,brutal_purge,soft_purge,[]}]}, + [{load_module,emqx_packet,brutal_purge,soft_purge,[]}, + {load_module,emqx_ws_connection,brutal_purge,soft_purge,[]} + ]}, {"4.3.2", [{load_module,emqx_packet,brutal_purge,soft_purge,[]}, + {load_module,emqx_ws_connection,brutal_purge,soft_purge,[]}, {load_module,emqx_http_lib,brutal_purge,soft_purge,[]}, {load_module,emqx_channel,brutal_purge,soft_purge,[]}, {load_module,emqx_app,brutal_purge,soft_purge,[]}, diff --git a/src/emqx_ws_connection.erl b/src/emqx_ws_connection.erl index 7bc68c271..d686e1611 100644 --- a/src/emqx_ws_connection.erl +++ b/src/emqx_ws_connection.erl @@ -403,7 +403,10 @@ websocket_close(Reason, State) -> terminate(Reason, _Req, #state{channel = Channel}) -> ?LOG(debug, "Terminated due to ~p", [Reason]), - emqx_channel:terminate(Reason, Channel). + emqx_channel:terminate(Reason, Channel); + +terminate(_Reason, _Req, _UnExpectedState) -> + ok. %%-------------------------------------------------------------------- %% Handle call