fix: re-add `list_subscriptions/0`
Created a ticket to add an actual working implementation
This commit is contained in:
parent
71f3efb2ce
commit
81fad58f12
|
@ -66,8 +66,11 @@
|
||||||
|
|
||||||
%% Subscriptions
|
%% Subscriptions
|
||||||
-export([
|
-export([
|
||||||
|
list_subscriptions/1,
|
||||||
list_subscriptions_via_topic/2,
|
list_subscriptions_via_topic/2,
|
||||||
list_subscriptions_via_topic/3
|
list_subscriptions_via_topic/3,
|
||||||
|
|
||||||
|
do_list_subscriptions/0
|
||||||
]).
|
]).
|
||||||
|
|
||||||
%% PubSub
|
%% PubSub
|
||||||
|
@ -394,6 +397,15 @@ call_client(Node, ClientId, Req) ->
|
||||||
%% Subscriptions
|
%% 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) ->
|
list_subscriptions_via_topic(Topic, FormatFun) ->
|
||||||
lists:append([
|
lists:append([
|
||||||
list_subscriptions_via_topic(Node, Topic, FormatFun)
|
list_subscriptions_via_topic(Node, Topic, FormatFun)
|
||||||
|
|
Loading…
Reference in New Issue