summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMichael Klishin <michael@rabbitmq.com>2014-07-01 10:32:11 +0400
committerMichael Klishin <michael@rabbitmq.com>2014-07-01 10:32:11 +0400
commit84e9f2a5461851b581b3e43f4a917a8457f1c7f7 (patch)
treece1762e13dfd475c4a47ba68b06ef52b4a3fe1f0
parent5c595f5966b41970ef603e4140473e9313e5cfb7 (diff)
downloadrabbitmq-server-84e9f2a5461851b581b3e43f4a917a8457f1c7f7.tar.gz
Use rabbit:is_running/1
-rw-r--r--src/rabbit_control_main.erl23
1 files changed, 9 insertions, 14 deletions
diff --git a/src/rabbit_control_main.erl b/src/rabbit_control_main.erl
index 00381224..645ac991 100644
--- a/src/rabbit_control_main.erl
+++ b/src/rabbit_control_main.erl
@@ -732,20 +732,15 @@ unsafe_rpc(Node, Mod, Fun, Args) ->
end.
ensure_app_running(Node) ->
- case rpc:call(Node, application, which_applications, [5000]) of
- {badrpc, Reason} ->
- fail_on_badrpc(Node, Reason);
- Apps ->
- case proplists:is_defined(rabbit, Apps) of
- true ->
- ok;
- false ->
- fmt_stderr("rabbit app is not running on node ~s, "
- "please start it with rabbitmqctl start_app "
- "and try again",
- [Node]),
- rabbit_misc:quit(2)
- end
+ case rabbit:is_running(Node) of
+ true ->
+ ok;
+ false ->
+ fmt_stderr("rabbit app is not running on node ~s, "
+ "please start it with rabbitmqctl start_app "
+ "and try again",
+ [Node]),
+ rabbit_misc:quit(2)
end.
call(Node, {Mod, Fun, Args}) ->