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 | 5bc69e976ef20a9bd2a53c92a134ec342ab443ce (patch) | |
| tree | a5993cc571a1dabf4e59f93f83d622b2bec54679 | |
| parent | c364af63ab622d886a7f1997873862a74816409a (diff) | |
| download | rabbitmq-server-git-5bc69e976ef20a9bd2a53c92a134ec342ab443ce.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 77706117cd..4f1f50a007 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. |