diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-01-31 12:10:37 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-01-31 12:10:37 +0000 |
| commit | d2121c1982cb50308305b50df8684f2531605cf1 (patch) | |
| tree | b6987a93818ed51c691b491790f57c1e7b2a3397 /src/rabbit.erl | |
| parent | a814f2e0e8e1ae7490e2b4d51034990bb8eafc76 (diff) | |
| download | rabbitmq-server-git-d2121c1982cb50308305b50df8684f2531605cf1.tar.gz | |
make cluster nofitication a boot step; don't print to screen
Diffstat (limited to 'src/rabbit.erl')
| -rw-r--r-- | src/rabbit.erl | 15 |
1 files changed, 5 insertions, 10 deletions
diff --git a/src/rabbit.erl b/src/rabbit.erl index 92bc8802f4..db4ae624b9 100644 --- a/src/rabbit.erl +++ b/src/rabbit.erl @@ -153,6 +153,11 @@ [{mfa, {rabbit_networking, boot, []}}, {requires, log_relay}]}). +-rabbit_boot_step({notify_cluster, + [{description, "notify cluster nodes"}, + {mfa, {rabbit_node_monitor, notify_cluster, []}}, + {requires, networking}]}). + %%--------------------------------------------------------------------------- -include("rabbit_framing.hrl"). @@ -230,16 +235,6 @@ start(normal, []) -> print_banner(), [ok = run_boot_step(Step) || Step <- boot_steps()], io:format("~nbroker running~n"), - io:format("informing other clustered brokers: ~p~n", - [rabbit_mnesia:running_clustered_nodes()]), - %% notify other rabbits of this rabbit - [ rpc:call(Node, rabbit_node_monitor, rabbit_running_on, [node()]) - || Node <- rabbit_mnesia:running_clustered_nodes(), - Node =/= node() ], - %% register other active rabbits with this rabbit - [ rabbit_node_monitor:rabbit_running_on(Node) - || Node <- rabbit_mnesia:running_clustered_nodes(), - Node =/= node() ], {ok, SupPid}; Error -> Error |