From 8f54572f9313348451345763351367d63190fa86 Mon Sep 17 00:00:00 2001 From: Feng Lee Date: Thu, 18 Aug 2016 15:54:02 +0800 Subject: [PATCH] run_hooks client.subscribe.after --- src/emqttd_session.erl | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/emqttd_session.erl b/src/emqttd_session.erl index 0e2df6b2e..bf475e4f6 100644 --- a/src/emqttd_session.erl +++ b/src/emqttd_session.erl @@ -315,6 +315,8 @@ handle_cast({subscribe, TopicTable, AckFun}, Session = #session{client_id = %% Where the Topic Filter is not identical to any existing Subscription’s filter, %% a new Subscription is created and all matching retained messages are sent. emqttd_retainer:dispatch(Topic1, self()), + emqttd:run_hooks('client.subscribe.after', [{ClientId, Username}], {Topic1, Opts1}), + dict:store(Topic1, NewQos, SubDict) end}; {stop, _} -> @@ -323,7 +325,6 @@ handle_cast({subscribe, TopicTable, AckFun}, Session = #session{client_id = end end, {[], Subscriptions}, TopicTable), AckFun(lists:reverse(GrantedQos)), - %%emqttd:run_hooks('client.subscribe.after', [ClientId], TopicTable), hibernate(Session#session{subscriptions = Subscriptions1}); %%TODO: 2.0 FIX