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

Merge pull request #8464 from lafirest/fix/stats_topic 

fix(stats): fix topic name error
This commit is contained in:
lafirest 2022-07-12 14:46:17 +08:00 committed by GitHub
parent 5bd1c4803c bcc16230cc
commit 265d3200c2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
apps/emqx/src/emqx_sys.erl
View File

@ -333,7 +333,7 @@ publish(brokers, Nodes) ->
safe_publish(<<"$SYS/brokers">>, #{retain => true}, Payload);
publish(stats, Stats) ->
[
safe_publish(systop(lists:concat(['stats/', Stat])), integer_to_binary(Val))
safe_publish(systop(stats_topic(Stat)), integer_to_binary(Val))
|| {Stat, Val} <- Stats, is_atom(Stat), is_integer(Val)
];
publish(metrics, Metrics) ->
@ -351,7 +351,13 @@ publish(Event, Payload) when
safe_publish(Topic, emqx_json:encode(Payload)).
metric_topic(Name) ->
lists:concat(["metrics/", string:replace(atom_to_list(Name), ".", "/", all)]).
translate_topic("metrics/", Name).
stats_topic(Name) ->
translate_topic("stats/", Name).
translate_topic(Prefix, Name) ->
lists:concat([Prefix, string:replace(atom_to_list(Name), ".", "/", all)]).
safe_publish(Topic, Payload) ->
safe_publish(Topic, #{}, Payload).