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]),