diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2011-03-30 12:45:54 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-03-30 12:45:54 +0100 |
| commit | 96c3724eb02795e9660b1924153abca2fad8a048 (patch) | |
| tree | a5c2477c4926c2bf1139278e369631eff3a90fdf /src | |
| parent | 068ce28bc9fa95e4213f2cba21ff6776c51a005c (diff) | |
| download | rabbitmq-server-git-96c3724eb02795e9660b1924153abca2fad8a048.tar.gz | |
cosmetic: put 'rabbitmqctl wait' code in the right place
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_control.erl | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/src/rabbit_control.erl b/src/rabbit_control.erl index 571eb5e4df..4a2858f072 100644 --- a/src/rabbit_control.erl +++ b/src/rabbit_control.erl @@ -127,6 +127,8 @@ usage() -> io:format("~s", [rabbit_ctl_usage:usage()]), quit(1). +%%---------------------------------------------------------------------------- + action(stop, Node, [], _Opts, Inform) -> Inform("Stopping and halting node ~p", [Node]), call(Node, {rabbit, stop_and_halt, []}); @@ -159,6 +161,10 @@ action(force_cluster, Node, ClusterNodeSs, _Opts, Inform) -> [Node, ClusterNodes]), rpc_call(Node, rabbit_mnesia, force_cluster, [ClusterNodes]); +action(wait, Node, [], _Opts, Inform) -> + Inform("Waiting for ~p", [Node]), + wait_for_application(Node, ?WAIT_FOR_VM_ATTEMPTS). + action(status, Node, [], _Opts, Inform) -> Inform("Status of node ~p", [Node]), case call(Node, {rabbit, status, []}) of @@ -294,9 +300,7 @@ action(list_permissions, Node, [], Opts, Inform) -> display_list(call(Node, {rabbit_auth_backend_internal, list_vhost_permissions, [VHost]})); -action(wait, Node, [], _Opts, Inform) -> - Inform("Waiting for ~p", [Node]), - wait_for_application(Node, ?WAIT_FOR_VM_ATTEMPTS). +%%---------------------------------------------------------------------------- wait_for_application(Node, Attempts) -> case rpc_call(Node, application, which_applications, [infinity]) of |