diff options
author | Michael Klishin <michael@rabbitmq.com> | 2014-07-28 09:03:01 +0400 |
---|---|---|
committer | Michael Klishin <michael@rabbitmq.com> | 2014-07-28 09:03:01 +0400 |
commit | 6e7793148d7e8fe2d1290e030b22f8593daaaad8 (patch) | |
tree | bce377e7e60ba6713928b95a06c0f00ebecbeffc | |
parent | 984a5291c37d67a7934377c8c722fce9587cea12 (diff) | |
download | rabbitmq-server-6e7793148d7e8fe2d1290e030b22f8593daaaad8.tar.gz |
Don't report nodedown issues as rabbit app not running
-rw-r--r-- | src/rabbit_control_main.erl | 18 |
1 files changed, 14 insertions, 4 deletions
diff --git a/src/rabbit_control_main.erl b/src/rabbit_control_main.erl index 1c32dc36..92712da9 100644 --- a/src/rabbit_control_main.erl +++ b/src/rabbit_control_main.erl @@ -146,8 +146,17 @@ start() -> Quiet = proplists:get_bool(?QUIET_OPT, Opts), Node = proplists:get_value(?NODE_OPT, Opts), case lists:member(Command, ?COMMANDS_NOT_REQUIRING_APP) of - false -> ensure_app_running(Node); - true -> ok + false -> + ensure_app_running(Node); + true -> + ok; + {badrpc, {'EXIT', Err}} -> + print_error("~p", [Err]), + rabbit_misc:quit(2); + {badrpc, Err} -> + print_error("unable to connect to node ~w: ~w", [Node, Err]), + print_badrpc_diagnostics([Node]), + rabbit_misc:quit(2) end, Inform = case Quiet of true -> fun (_Format, _Args1) -> ok end; @@ -725,13 +734,14 @@ unsafe_rpc(Node, Mod, Fun, Args) -> end. ensure_app_running(Node) -> - case rabbit:is_running(Node) of + case call(Node, {rabbit, is_running, []}) 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) + rabbit_misc:quit(2); + Other -> Other end. call(Node, {Mod, Fun, Args}) -> |