From de9e619c96fb938ce2621a09ce47c854b2842e2b Mon Sep 17 00:00:00 2001 From: Thales Macedo Garitezi Date: Wed, 7 Aug 2024 10:41:48 -0300 Subject: [PATCH] fix: use ekka when performing `emqx ctl cluster *` Fixes https://emqx.atlassian.net/browse/EMQX-12824 --- apps/emqx_management/src/emqx_mgmt_cli.erl | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/apps/emqx_management/src/emqx_mgmt_cli.erl b/apps/emqx_management/src/emqx_mgmt_cli.erl index 035af188f..ebc05e3b7 100644 --- a/apps/emqx_management/src/emqx_mgmt_cli.erl +++ b/apps/emqx_management/src/emqx_mgmt_cli.erl @@ -97,7 +97,7 @@ broker(_) -> %% @doc Cluster with other nodes cluster(["join", SNode]) -> - case mria:join(ekka_node:parse_name(SNode)) of + case ekka:join(ekka_node:parse_name(SNode)) of ok -> emqx_ctl:print("Join the cluster successfully.~n"), %% FIXME: running status on the replicant immediately @@ -112,7 +112,7 @@ cluster(["join", SNode]) -> end; cluster(["leave"]) -> _ = maybe_disable_autocluster(), - case mria:leave() of + case ekka:leave() of ok -> emqx_ctl:print("Leave the cluster successfully.~n"), cluster(["status"]); @@ -121,7 +121,7 @@ cluster(["leave"]) -> end; cluster(["force-leave", SNode]) -> Node = ekka_node:parse_name(SNode), - case mria:force_leave(Node) of + case ekka:force_leave(Node) of ok -> case emqx_cluster_rpc:force_leave_clean(Node) of ok ->