yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Improve the print of 'subscriptions' CLI

This commit is contained in:
Feng Lee 2017-11-18 12:25:00 +08:00
parent d58b8bed3c
commit 1d0e17b89c
1 changed files with 14 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/emqttd_cli.erl
View File

@ -256,7 +256,8 @@ 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), [{qos, IntQos}]}]), {Topic1, Options} = emqttd_topic:parse(bin(Topic)),
emqttd_session:subscribe(SessPid, [{Topic1, [{qos, IntQos}|Options]}]),
?PRINT_MSG("ok~n") ?PRINT_MSG("ok~n")
end end
end); end);
@ -266,7 +267,7 @@ subscriptions(["del", ClientId, Topic]) ->
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:unsubscribe(SessPid, [bin(Topic)]), emqttd_session:unsubscribe(SessPid, [emqttd_topic:parse(bin(Topic))]),
?PRINT_MSG("ok~n") ?PRINT_MSG("ok~n")
end; end;
@ -586,7 +587,16 @@ print(subscription, {{SubId, SubPid}, {share, _Share, Topic}})
?PRINT("~s~p -> ~s~n", [SubId, SubPid, Topic]); ?PRINT("~s~p -> ~s~n", [SubId, SubPid, Topic]);
print(subscription, {{SubId, SubPid}, Topic}) print(subscription, {{SubId, SubPid}, Topic})
when is_binary(SubId), is_pid(SubPid) -> when is_binary(SubId), is_pid(SubPid) ->
?PRINT("~s~p -> ~s~n", [SubId, SubPid, Topic]). ?PRINT("~s~p -> ~s~n", [SubId, SubPid, Topic]);
print(subscription, {Sub, Topic, Props}) ->
print(subscription, {Sub, Topic}),
lists:foreach(fun({K, V}) when is_binary(V) ->
?PRINT(" ~-8s: ~s~n", [K, V]);
({K, V}) ->
?PRINT(" ~-8s: ~w~n", [K, V]);
(K) ->
?PRINT(" ~-8s: true~n", [K])
end, Props).
format(created_at, Val) -> format(created_at, Val) ->
emqttd_time:now_secs(Val); emqttd_time:now_secs(Val);