diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2012-04-19 17:03:12 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2012-04-19 17:03:12 +0100 |
| commit | 3105f1a500d2d957083e564d7405ce1d4a50cd40 (patch) | |
| tree | 2a37994939cd78f87eecee180c7d9b704a8d507a | |
| parent | 06f918c2b250299a4fe21dffb2a7cae0ede4a4a3 (diff) | |
| download | rabbitmq-server-3105f1a500d2d957083e564d7405ce1d4a50cd40.tar.gz | |
cosmetic
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 19 |
1 files changed, 9 insertions, 10 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 064df26f..19333fb9 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -1241,16 +1241,15 @@ handle_cast({reject, AckTags, Requeue, ChPid}, State) -> noreply(subtract_acks( ChPid, AckTags, State, case Requeue of - true -> - fun (State1) -> requeue_and_run(AckTags, State1) end; - false -> - fun (State1 = #q{backing_queue = BQ, - backing_queue_state = BQS}) -> - Fun = dead_letter_fun(rejected, State1), - BQS1 = BQ:fold(Fun, BQS, AckTags), - ack_if_no_dlx( - AckTags, State1#q{backing_queue_state = BQS1}) - end + true -> fun (State1) -> requeue_and_run(AckTags, State1) end; + false -> fun (State1 = #q{backing_queue = BQ, + backing_queue_state = BQS}) -> + Fun = dead_letter_fun(rejected, State1), + BQS1 = BQ:fold(Fun, BQS, AckTags), + ack_if_no_dlx( + AckTags, + State1#q{backing_queue_state = BQS1}) + end end)); handle_cast(delete_immediately, State) -> |