This commit is contained in:
Feng Lee 2016-08-10 22:30:02 +08:00
parent e2dab894af
commit 8a0a7978dd
1 changed files with 2 additions and 1 deletions

View File

@ -50,7 +50,8 @@ on_client_disconnected(Reason, ClientId, Opts) ->
{reason, reason(Reason)},
{ts, emqttd_time:now_to_secs()}]),
Msg = message(qos(Opts), topic(disconnected, ClientId), Json),
emqttd:publish(emqttd_message:set_flag(sys, Msg)).
emqttd:publish(emqttd_message:set_flag(sys, Msg)),
ok.
unload(_Opts) ->
emqttd:unhook('client.connected', fun ?MODULE:on_client_connected/3),