|
@@ -290,11 +290,11 @@ topic_metrics(post, #{body := #{<<"topic">> := Topic}}) ->
|
|
|
reason2httpresp(Reason)
|
|
reason2httpresp(Reason)
|
|
|
end.
|
|
end.
|
|
|
|
|
|
|
|
-operate_topic_metrics(get, #{bindings := #{topic := Topic0}}) ->
|
|
|
|
|
- get_cluster_response([emqx_http_lib:uri_decode(Topic0)]);
|
|
|
|
|
|
|
+operate_topic_metrics(get, #{bindings := #{topic := Topic}}) ->
|
|
|
|
|
+ get_cluster_response([Topic]);
|
|
|
|
|
|
|
|
-operate_topic_metrics(delete, #{bindings := #{topic := Topic0}}) ->
|
|
|
|
|
- case emqx_modules_conf:remove_topic_metrics(emqx_http_lib:uri_decode(Topic0)) of
|
|
|
|
|
|
|
+operate_topic_metrics(delete, #{bindings := #{topic := Topic}}) ->
|
|
|
|
|
+ case emqx_modules_conf:remove_topic_metrics(Topic) of
|
|
|
ok -> {204};
|
|
ok -> {204};
|
|
|
{error, Reason} -> reason2httpresp(Reason)
|
|
{error, Reason} -> reason2httpresp(Reason)
|
|
|
end.
|
|
end.
|