diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-09-24 23:15:39 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-09-24 23:15:39 +0100 |
| commit | 0fdf84d0394ecf55c7be591662a3e9aa297d374b (patch) | |
| tree | d8200bbe041c08d66fef563d10b4d50f9aa88f0a /src | |
| parent | d4e44ca0596f589b9f8783152926b0415b2b78ca (diff) | |
| download | rabbitmq-server-git-0fdf84d0394ecf55c7be591662a3e9aa297d374b.tar.gz | |
cosmetic
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_node_monitor.erl | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/src/rabbit_node_monitor.erl b/src/rabbit_node_monitor.erl index 38493db1bb..f906e9f1ff 100644 --- a/src/rabbit_node_monitor.erl +++ b/src/rabbit_node_monitor.erl @@ -146,24 +146,15 @@ reset_cluster_status() -> %% Cluster notifications %%---------------------------------------------------------------------------- -joined_cluster(Node, IsDiscNode) -> - gen_server:cast(?SERVER, {rabbit_join, Node, IsDiscNode}). - notify_joined_cluster() -> cluster_multicall(joined_cluster, [node(), rabbit_mnesia:node_type()]), ok. -left_cluster(Node) -> - gen_server:cast(?SERVER, {left_cluster, Node}). - notify_left_cluster(Node) -> left_cluster(Node), cluster_multicall(left_cluster, [Node]), ok. -node_up(Node, IsDiscNode) -> - gen_server:cast(?SERVER, {node_up, Node, IsDiscNode}). - notify_node_up() -> Nodes = cluster_multicall(node_up, [node(), rabbit_mnesia:node_type()]), %% register other active rabbits with this rabbit @@ -171,6 +162,15 @@ notify_node_up() -> N <- Nodes ], ok. +joined_cluster(Node, NodeType) -> + gen_server:cast(?SERVER, {rabbit_join, Node, NodeType}). + +left_cluster(Node) -> + gen_server:cast(?SERVER, {left_cluster, Node}). + +node_up(Node, IsDiscNode) -> + gen_server:cast(?SERVER, {node_up, Node, IsDiscNode}). + %%---------------------------------------------------------------------------- %% gen_server callbacks %%---------------------------------------------------------------------------- |