diff --git a/src/emqttd_session.erl b/src/emqttd_session.erl
index 4d920fffb..0d27a1cbd 100644
--- a/src/emqttd_session.erl
+++ b/src/emqttd_session.erl
@@ -386,6 +386,7 @@ handle_cast({subscribe, _From, TopicTable, AckFun},
                 SubMap1 =
                 case maps:find(Topic, SubMap) of
                     {ok, NewQos} ->
+                        emqttd_hooks:run('session.subscribed', [ClientId, Username], {Topic, Opts}),
                         ?LOG(warning, "Duplicated subscribe: ~s, qos = ~w", [Topic, NewQos], State),
                         SubMap;
                     {ok, OldQos} ->