Fix the issue that we cannot remove a down node from the cluster

2017-06-13 10:35:22 +08:00 · 2017-06-13 10:35:22 +08:00 · 79c2fa631e
parent a5cac277c1
commit 79c2fa631e
1 changed files with 1 additions and 1 deletions
--- a/src/emqttd_cluster.erl
+++ b/src/emqttd_cluster.erl
@ -50,7 +50,7 @@ prepare() ->
 %% @doc Is node in cluster?
 -spec(is_clustered(node()) -> boolean()).
 is_clustered(Node) ->
-    lists:member(Node, emqttd_mnesia:running_nodes()).
+    lists:member(Node, emqttd_mnesia:cluster_nodes(all)).

 %% @doc Reboot after join or leave cluster.
 -spec(reboot() -> ok).