Add run hook when duplicated subscription

2018-09-08 18:59:57 +08:00 · 2018-09-08 18:59:57 +08:00 · 5b47df1631
parent 758d18e21f
commit 5b47df1631
1 changed files with 1 additions and 0 deletions
--- a/src/emqx_session.erl
+++ b/src/emqx_session.erl
@ -444,6 +444,7 @@ handle_cast({subscribe, FromPid, {PacketId, _Properties, TopicFilters}},
        lists:foldr(fun({Topic, SubOpts = #{qos := QoS}}, {RcAcc, SubMap}) ->
                            {[QoS|RcAcc], case maps:find(Topic, SubMap) of
                                              {ok, SubOpts} ->
+                                                  emqx_hooks:run('session.subscribed', [#{client_id => ClientId}, Topic, SubOpts#{first => false}]),
                                                  SubMap;
                                              {ok, _SubOpts} ->
                                                  emqx_broker:set_subopts(Topic, {self(), ClientId}, SubOpts),