From cd147c453f8216dd780abb260f6732b57059f8de Mon Sep 17 00:00:00 2001 From: Feng Date: Thu, 16 Jul 2015 17:06:15 +0800 Subject: [PATCH] fix issue #196 --- src/emqttd_session.erl | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/emqttd_session.erl b/src/emqttd_session.erl index 1a5797631..930454667 100644 --- 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]),