|
|
@@ -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 ->
|