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 | b26a13371e30a09281d2f3d4d1d8db804682403d (patch) | |
| tree | 317db48716359f947001cf5a88c6f991814a8562 | |
| parent | 4d90b2208ca460ad285f1c38b45f0749c88d7223 (diff) | |
| download | rabbitmq-server-b26a13371e30a09281d2f3d4d1d8db804682403d.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 9381774d..ab735be6 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}; |