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 | 8c1088a4be2fb28a6b681a3972e47223efea4712 (patch) | |
| tree | bce377e7e60ba6713928b95a06c0f00ebecbeffc | |
| parent | 0e0a03bb71f43ba7e08527c794b3c98e34c6e8d5 (diff) | |
| download | rabbitmq-server-git-8c1088a4be2fb28a6b681a3972e47223efea4712.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 1c32dc368f..92712da9da 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}) -> |
