diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2011-03-14 11:30:23 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2011-03-14 11:30:23 +0000 |
| commit | 8492c18d696b0d4b384bfdc381d006e421351658 (patch) | |
| tree | a5993cc571a1dabf4e59f93f83d622b2bec54679 | |
| parent | 83c80cfc25ba8be3aded02647b35e3778a4d4c8f (diff) | |
| download | rabbitmq-server-8492c18d696b0d4b384bfdc381d006e421351658.tar.gz | |
Maintain an acceptable level of code quality.
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 77706117..4f1f50a0 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -217,12 +217,11 @@ noreply(NewState) -> next_state(State = #q{backing_queue = BQ, backing_queue_state = BQS}) -> {MsgIds, BQS1} = BQ:drain_confirmed(BQS), - BQNeedsSync = BQ:needs_idle_timeout(BQS1), State1 = ensure_stats_timer( ensure_rate_timer( confirm_messages(MsgIds, State#q{ backing_queue_state = BQS1}))), - case BQNeedsSync of + case BQ:needs_idle_timeout(BQS1) of true -> {ensure_sync_timer(State1), 0}; false -> {stop_sync_timer(State1), hibernate} end. |