Merge pull request #1639 from Gilbert-Wong/issue#1614

fix bug for issue#1614
2018-06-30 22:52:43 +08:00 · 2018-06-30 22:52:43 +08:00 · aa6ae3ad8a
parent 8d6a78ce8e d7e46b367e
commit aa6ae3ad8a
1 changed files with 1 additions and 0 deletions
--- 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} ->