fix bug for issue#1614
This commit is contained in:
parent
f9dde2f049
commit
d7e46b367e
|
@ -386,6 +386,7 @@ handle_cast({subscribe, _From, TopicTable, AckFun},
|
||||||
SubMap1 =
|
SubMap1 =
|
||||||
case maps:find(Topic, SubMap) of
|
case maps:find(Topic, SubMap) of
|
||||||
{ok, NewQos} ->
|
{ok, NewQos} ->
|
||||||
|
emqttd_hooks:run('session.subscribed', [ClientId, Username], {Topic, Opts}),
|
||||||
?LOG(warning, "Duplicated subscribe: ~s, qos = ~w", [Topic, NewQos], State),
|
?LOG(warning, "Duplicated subscribe: ~s, qos = ~w", [Topic, NewQos], State),
|
||||||
SubMap;
|
SubMap;
|
||||||
{ok, OldQos} ->
|
{ok, OldQos} ->
|
||||||
|
|
Loading…
Reference in New Issue