diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-09-27 12:49:21 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-09-27 12:49:21 +0100 |
| commit | 7839b217164b9a9f089fed001253c74d8c0954cf (patch) | |
| tree | 181bb464b7fa530ee7a073a7f01b48c9f5c04ad1 | |
| parent | 8d52df02cc34781ab28303ee7d1013f36604d641 (diff) | |
| download | rabbitmq-server-7839b217164b9a9f089fed001253c74d8c0954cf.tar.gz | |
cosmetic
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 487c06b7..10ac5bea 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -169,11 +169,9 @@ init_with_backing_queue_state(Q = #amqqueue{exclusive_owner = Owner}, BQ, BQS, State1 = requeue_and_run(AckTags, process_args( rabbit_event:init_stats_timer( State, #q.stats_timer))), - lists:foldl( - fun (Delivery, StateN) -> - deliver_or_enqueue(Delivery, true, StateN) - end, - State1, Deliveries). + lists:foldl(fun (Delivery, StateN) -> + deliver_or_enqueue(Delivery, true, StateN) + end, State1, Deliveries). terminate(shutdown = R, State = #q{backing_queue = BQ}) -> terminate_shutdown(fun (BQS) -> BQ:terminate(R, BQS) end, State); |