diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-12-12 18:11:24 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-12-12 18:11:24 +0000 |
| commit | 3b4789453a25f377e09bbe4d5646b9d6fc92cc83 (patch) | |
| tree | 317db48716359f947001cf5a88c6f991814a8562 | |
| parent | 001dff7d25ed8b8d9f3f94b976ba6b1e1afc71c9 (diff) | |
| download | rabbitmq-server-git-3b4789453a25f377e09bbe4d5646b9d6fc92cc83.tar.gz | |
Reminder
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 2 |
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}; |
