From 81fad58f12db7d63dd9c3c7562c4b6928d74324b Mon Sep 17 00:00:00 2001 From: Stefan Strigler Date: Mon, 20 Feb 2023 10:47:25 +0100 Subject: [PATCH] fix: re-add `list_subscriptions/0` Created a ticket to add an actual working implementation --- apps/emqx_management/src/emqx_mgmt.erl | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) diff --git a/apps/emqx_management/src/emqx_mgmt.erl b/apps/emqx_management/src/emqx_mgmt.erl index e7c338adf..efa5a03bd 100644 --- a/apps/emqx_management/src/emqx_mgmt.erl +++ b/apps/emqx_management/src/emqx_mgmt.erl @@ -66,8 +66,11 @@ %% Subscriptions -export([ + list_subscriptions/1, list_subscriptions_via_topic/2, - list_subscriptions_via_topic/3 + list_subscriptions_via_topic/3, + + do_list_subscriptions/0 ]). %% PubSub @@ -394,6 +397,15 @@ call_client(Node, ClientId, Req) -> %% Subscriptions %%-------------------------------------------------------------------- +-spec do_list_subscriptions() -> no_return(). +do_list_subscriptions() -> + %% [FIXME] Add function to `emqx_broker` that returns list of subscriptions + %% and either redirect from here or bpapi directly (EMQX-8993). + throw(not_implemented). + +list_subscriptions(Node) -> + unwrap_rpc(emqx_management_proto_v3:list_subscriptions(Node)). + list_subscriptions_via_topic(Topic, FormatFun) -> lists:append([ list_subscriptions_via_topic(Node, Topic, FormatFun)