Fix the 'subscriptions add <ClientId> <Topic> <Qos>' CLI

This commit is contained in:
Feng Lee 2017-11-18 11:48:44 +08:00
parent 405d5d9d29
commit d58b8bed3c
1 changed files with 1 additions and 1 deletions

View File

@ -256,7 +256,7 @@ subscriptions(["add", ClientId, Topic, QoS]) ->
undefined -> undefined ->
?PRINT_MSG("Error: Session not found!"); ?PRINT_MSG("Error: Session not found!");
#mqtt_session{sess_pid = SessPid} -> #mqtt_session{sess_pid = SessPid} ->
emqttd_session:subscribe(SessPid, [{bin(Topic), IntQos}]), emqttd_session:subscribe(SessPid, [{bin(Topic), [{qos, IntQos}]}]),
?PRINT_MSG("ok~n") ?PRINT_MSG("ok~n")
end end
end); end);