fix(exproto): handle discard call

2022-02-17 09:35:30 +08:00 · 2022-02-17 09:35:30 +08:00 · 7236206373
parent bf565efc99
commit 7236206373
1 changed files with 3 additions and 0 deletions
--- a/apps/emqx_exproto/src/emqx_exproto_channel.erl
+++ b/apps/emqx_exproto/src/emqx_exproto_channel.erl
@ -366,6 +366,9 @@ handle_call({publish, Topic, Qos, Payload},
 handle_call(kick, Channel) ->
    {shutdown, kicked, ok, Channel};

+handle_call(discard, Channel) ->
+    {shutdown, discarded, ok, Channel};
+
 handle_call(Req, Channel) ->
    ?LOG(warning, "Unexpected call: ~p", [Req]),
    {reply, {error, unexpected_call}, Channel}.