From 48a761c4066a8be6ae1c7d42b7e78db286b1e58c Mon Sep 17 00:00:00 2001 From: firest Date: Mon, 15 Aug 2022 17:21:39 +0800 Subject: [PATCH] fix(mgmt): fix `$queue` topic name error in this API return --- apps/emqx_management/src/emqx_mgmt_api_subscriptions.erl | 2 ++ 1 file changed, 2 insertions(+) diff --git a/apps/emqx_management/src/emqx_mgmt_api_subscriptions.erl b/apps/emqx_management/src/emqx_mgmt_api_subscriptions.erl index 7c7173a46..470242cfd 100644 --- a/apps/emqx_management/src/emqx_mgmt_api_subscriptions.erl +++ b/apps/emqx_management/src/emqx_mgmt_api_subscriptions.erl @@ -177,6 +177,8 @@ format({_Subscriber, Topic, Options}) -> maps:with([qos, nl, rap, rh], Options) ). +get_topic(Topic, #{share := <<"$queue">> = Group}) -> + filename:join([Group, Topic]); get_topic(Topic, #{share := Group}) -> filename:join([<<"$share">>, Group, Topic]); get_topic(Topic, _) ->