From 77616f47214de55944833c1e657c4f87db02ad57 Mon Sep 17 00:00:00 2001 From: terry-xiaoyu <506895667@qq.com> Date: Fri, 9 Aug 2019 19:25:14 +0800 Subject: [PATCH] Add hook client.disconnected --- src/emqx_protocol.erl | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/emqx_protocol.erl b/src/emqx_protocol.erl index d9a2e8496..3fa92ac70 100644 --- a/src/emqx_protocol.erl +++ b/src/emqx_protocol.erl @@ -437,9 +437,10 @@ handle_timeout(TRef, Msg, PState = #protocol{session = Session}) -> handle_out({publish, Publishes}, PState#protocol{session = NSession}) end. -terminate(normal, _PState) -> - ok; -terminate(_Reason, #protocol{will_msg = WillMsg}) -> +terminate(normal, #protocol{client = Client}) -> + ok = emqx_hooks:run('client.disconnected', [Client, normal]); +terminate(Reason, #protocol{client = Client, will_msg = WillMsg}) -> + ok = emqx_hooks:run('client.disconnected', [Client, Reason]), publish_will_msg(WillMsg). publish_will_msg(undefined) ->