yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add hook client.disconnected

This commit is contained in:
terry-xiaoyu 2019-08-09 19:25:14 +08:00
parent a19777c2e6
commit 77616f4721
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/emqx_protocol.erl
View File

@ -437,9 +437,10 @@ handle_timeout(TRef, Msg, PState = #protocol{session = Session}) ->
handle_out({publish, Publishes}, PState#protocol{session = NSession}) handle_out({publish, Publishes}, PState#protocol{session = NSession})
end. end.
terminate(normal, _PState) -> terminate(normal, #protocol{client = Client}) ->
ok; ok = emqx_hooks:run('client.disconnected', [Client, normal]);
terminate(_Reason, #protocol{will_msg = WillMsg}) -> terminate(Reason, #protocol{client = Client, will_msg = WillMsg}) ->
ok = emqx_hooks:run('client.disconnected', [Client, Reason]),
publish_will_msg(WillMsg). publish_will_msg(WillMsg).
publish_will_msg(undefined) -> publish_will_msg(undefined) ->