From fa99cdcaa55ec9760d86fd5188af3f061fcaafd2 Mon Sep 17 00:00:00 2001 From: huangdan Date: Thu, 8 Dec 2016 19:34:38 +0800 Subject: [PATCH] Local Subscription Routes show --- src/emqttd_cli.erl | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/src/emqttd_cli.erl b/src/emqttd_cli.erl index 0ec4f3680..547f25e81 100644 --- a/src/emqttd_cli.erl +++ b/src/emqttd_cli.erl @@ -195,7 +195,8 @@ sessions(_) -> %%-------------------------------------------------------------------- %% @doc Routes Command routes(["list"]) -> - if_could_print(mqtt_route, fun print/1); + Routes = emqttd_router:dump(), + foreach(fun print/1, Routes); routes(["show", Topic]) -> print(mnesia:dirty_read(mqtt_route, bin(Topic))); @@ -506,9 +507,14 @@ print(#mqtt_client{client_id = ClientId, clean_sess = CleanSess, username = User %% print(#mqtt_topic{topic = Topic, flags = Flags}) -> %% ?PRINT("~s: ~s~n", [Topic, string:join([atom_to_list(F) || F <- Flags], ",")]); - +print({route, Routes}) -> + foreach(fun print/1, Routes); +print({local_route, Routes}) -> + foreach(fun print/1, Routes); print(#mqtt_route{topic = Topic, node = Node}) -> ?PRINT("~s -> ~s~n", [Topic, Node]); +print({Topic, Node}) -> + ?PRINT("~s -> ~s~n", [Topic, Node]); print({ClientId, _ClientPid, _Persistent, SessInfo}) -> InfoKeys = [clean_sess,