diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-03-29 17:36:36 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-03-29 17:36:36 +0100 |
| commit | 1df39e0c1fad2f0fb2df0e18c7fb7db8359c10f3 (patch) | |
| tree | ba84c09bcc786d81306acc3ffb15f41dafcc5cf6 | |
| parent | c9a9748ef48f488f981f82d79e9c0cee83c2a211 (diff) | |
| download | rabbitmq-server-1df39e0c1fad2f0fb2df0e18c7fb7db8359c10f3.tar.gz | |
We don't need this any more, just inform the registree once.
| -rw-r--r-- | src/rabbit_alarm.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_alarm.erl b/src/rabbit_alarm.erl index f5e098c5..04e0c141 100644 --- a/src/rabbit_alarm.erl +++ b/src/rabbit_alarm.erl @@ -181,8 +181,8 @@ internal_register(Pid, {M, F, A} = HighMemMFA, State = #alarms{alertees = Alertees}) -> _MRef = erlang:monitor(process, Pid), case dict:find(node(), State#alarms.alarmed_nodes) of - {ok, Sources} -> [apply(M, F, A ++ [Pid, true]) || R <- Sources]; - error -> ok + {ok, _Sources} -> apply(M, F, A ++ [Pid, true]); + error -> ok end, NewAlertees = dict:store(Pid, HighMemMFA, Alertees), State#alarms{alertees = NewAlertees}. |