summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2012-12-12 18:11:24 +0000
committerSimon MacMullen <simon@rabbitmq.com>2012-12-12 18:11:24 +0000
commit3b4789453a25f377e09bbe4d5646b9d6fc92cc83 (patch)
tree317db48716359f947001cf5a88c6f991814a8562
parent001dff7d25ed8b8d9f3f94b976ba6b1e1afc71c9 (diff)
downloadrabbitmq-server-git-3b4789453a25f377e09bbe4d5646b9d6fc92cc83.tar.gz
Reminder
-rw-r--r--src/rabbit_amqqueue_process.erl2
1 files changed, 2 insertions, 0 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl
index 9381774de9..ab735be6dd 100644
--- a/src/rabbit_amqqueue_process.erl
+++ b/src/rabbit_amqqueue_process.erl
@@ -1314,6 +1314,7 @@ handle_info(drop_expired, State) ->
handle_info(emit_stats, State) ->
emit_stats(State),
+ %% Don't call noreply/1, we don't want to set timers
{State1, Timeout} = next_state(rabbit_event:reset_stats_timer(
State, #q.stats_timer)),
{noreply, State1, Timeout};
@@ -1340,6 +1341,7 @@ handle_info(update_ram_duration, State = #q{backing_queue = BQ,
DesiredDuration =
rabbit_memory_monitor:report_ram_duration(self(), RamDuration),
BQS2 = BQ:set_ram_duration_target(DesiredDuration, BQS1),
+ %% Don't call noreply/1, we don't want to set timers
{State1, Timeout} = next_state(State#q{rate_timer_ref = undefined,
backing_queue_state = BQS2}),
{noreply, State1, Timeout};