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

perf(mgmt): optimize bulk unsubscribe when registry is enabled

This commit is contained in:
Thales Macedo Garitezi 2024-06-27 09:52:32 -03:00
parent 0b329dbf06
commit e76e94b497
1 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
apps/emqx_management/src/emqx_mgmt.erl
View File

@ -626,7 +626,18 @@ do_unsubscribe(ClientId, Topic) ->
-spec unsubscribe_batch(emqx_types:clientid(), [emqx_types:topic()]) -> -spec unsubscribe_batch(emqx_types:clientid(), [emqx_types:topic()]) ->
{unsubscribe, _} | {error, channel_not_found}. {unsubscribe, _} | {error, channel_not_found}.
unsubscribe_batch(ClientId, Topics) -> unsubscribe_batch(ClientId, Topics) ->
unsubscribe_batch(emqx:running_nodes(), ClientId, Topics). case emqx_cm_registry:is_enabled() of
false ->
unsubscribe_batch(emqx:running_nodes(), ClientId, Topics);
true ->
with_client_node(
ClientId,
{error, channel_not_found},
fun(Node) ->
unsubscribe_batch([Node], ClientId, Topics)
end
)
end.
-spec unsubscribe_batch([node()], emqx_types:clientid(), [emqx_types:topic()]) -> -spec unsubscribe_batch([node()], emqx_types:clientid(), [emqx_types:topic()]) ->
{unsubscribe_batch, _} | {error, channel_not_found}. {unsubscribe_batch, _} | {error, channel_not_found}.