fix issue #196

2015-07-16 17:06:15 +08:00 · 2015-07-16 17:06:15 +08:00 · cd147c453f
parent 5c46004c18
commit cd147c453f
1 changed files with 2 additions and 0 deletions
--- a/src/emqttd_session.erl
+++ b/src/emqttd_session.erl
@ -242,6 +242,8 @@ handle_call({subscribe, TopicTable0}, _From, Session = #session{client_id = Clie
    %% subscribe first and don't care if the subscriptions have been existed
    {ok, GrantedQos} = emqttd_pubsub:subscribe(TopicTable),

+    emqttd_broker:foreach_hooks('client.subscribe.after', [ClientId, TopicTable]),
+
    lager:info([{client, ClientId}], "Session ~s subscribe ~p, Granted QoS: ~p",
                [ClientId, TopicTable, GrantedQos]),