summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorFrancesco Mazzoli <francesco@rabbitmq.com>2012-07-11 13:32:28 +0100
committerFrancesco Mazzoli <francesco@rabbitmq.com>2012-07-11 13:32:28 +0100
commite5ad74e22a52bb57cdae07eaecb6c07ed26b0dd4 (patch)
tree1094e2f3536ff5a9b879513ce8712333c279e288
parentb740677bf32ed4bb92d0373297723ec82cc24afd (diff)
downloadrabbitmq-server-git-e5ad74e22a52bb57cdae07eaecb6c07ed26b0dd4.tar.gz
log the resource limit alarms
-rw-r--r--src/rabbit_alarm.erl6
1 files changed, 4 insertions, 2 deletions
diff --git a/src/rabbit_alarm.erl b/src/rabbit_alarm.erl
index 1fb2056e74..9d1667171c 100644
--- a/src/rabbit_alarm.erl
+++ b/src/rabbit_alarm.erl
@@ -96,11 +96,13 @@ handle_call(_Request, State) ->
{ok, not_understood, State}.
handle_event({set_alarm, {{resource_limit, Source, Node}, []}}, State) ->
- %% TODO: Do some logging
+ rabbit_log:warning("'~p' resource limit alarm set on node ~p",
+ [Source, Node]),
{ok, maybe_alert(fun dict:append/3, Node, Source, State)};
handle_event({clear_alarm, {resource_limit, Source, Node}}, State) ->
- %% TODO: Do some logging
+ rabbit_log:warning("'~p' resource limit alarm cleared on node ~p",
+ [Source, Node]),
{ok, maybe_alert(fun dict_unappend/3, Node, Source, State)};
handle_event({node_up, Node}, State) ->