anchor.diff:              end, lists:sort(emqttd_metrics:all()));
   
   broker(["pubsub"]) ->
  -    Pubsubs = supervisor:which_children(emqttd_pubsub_sup),
  +    Pubsubs = supervisor:which_children(emqttd_pubsub_sup:pubsub_pool()),
       foreach(fun({{_, Id}, Pid, _, _}) ->
                   ProcInfo = erlang:process_info(Pid, ?PROC_INFOKEYS),
                   ?PRINT("pubsub: ~w~n", [Id]),
  
positive.code:             {"trace topic <Topic> off",          "stop to trace Topic"}]).
  
  trace_on(Who, Name, LogFile) ->
      case emqttd_trace:start_trace({Who, bin(Name)}, LogFile) of
          ok ->
              ?PRINT("trace ~s ~s successfully.~n", [Who, Name]);
          {error, Error} ->
  
negative.code: 
  bridges(["list"]) ->
      foreach(fun({{Node, Topic}, _Pid}) ->
                  ?PRINT("bridge: ~s--~s-->~s~n", [node(), Topic, Node])
              end, emqttd_bridge_sup:bridges());
  
  bridges(["options"]) ->
  