diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-01-25 13:04:59 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-01-25 13:04:59 +0000 |
| commit | 50656f5f4439869590134e7704e71268bf293ca9 (patch) | |
| tree | 12323e47876d6fea241bf8192c32322a636ac451 | |
| parent | 2142727b3c532f9657d1fa47913323b48a424e2e (diff) | |
| download | rabbitmq-server-50656f5f4439869590134e7704e71268bf293ca9.tar.gz | |
monitor the rabbit app on some remote nodes
| -rw-r--r-- | src/rabbit_node_monitor.erl | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/rabbit_node_monitor.erl b/src/rabbit_node_monitor.erl index e4bc1cdc..bce5ec12 100644 --- a/src/rabbit_node_monitor.erl +++ b/src/rabbit_node_monitor.erl @@ -44,6 +44,8 @@ handle_cast(_Msg, State) -> handle_info({nodeup, Node}, State) -> rabbit_log:info("node ~p up", [Node]), + erlang:monitor(process, {rabbit, Node}), + io:format("monitored 'rabbit' on ~p~n", [Node]), {noreply, State}; handle_info({nodedown, Node}, State) -> rabbit_log:info("node ~p down", [Node]), @@ -53,6 +55,9 @@ handle_info({nodedown, Node}, State) -> ok = rabbit_networking:on_node_down(Node), ok = rabbit_amqqueue:on_node_down(Node), {noreply, State}; +handle_info({'DOWN', _MRef, process, {rabbit, Node}, _Reason}, State) -> + io:format("node ~p lost 'rabbit'~n", [Node]), + {noreply, State}; handle_info(_Info, State) -> {noreply, State}. |