diff options
author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-07-26 16:17:38 +0100 |
---|---|---|
committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-07-26 16:17:38 +0100 |
commit | bdf102c7b44dca971fced0dfe75fa2a09b07f06b (patch) | |
tree | f90e4ae629e86ba7f5b1a83030813b9bbad1bbb1 | |
parent | 9d7b2f212b0ce1daa03f9595e85134c72f839cbc (diff) | |
download | rabbitmq-server-bdf102c7b44dca971fced0dfe75fa2a09b07f06b.tar.gz |
cosmetic
Not sure how the misaligned -> happened..
-rw-r--r-- | src/rabbit_channel.erl | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 7e9e1b29..2829d397 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -805,7 +805,7 @@ handle_method(#'basic.qos'{prefetch_count = PrefetchCount}, _, {_, _} -> Limiter end, Limiter3 = case rabbit_limiter:limit(Limiter1, PrefetchCount) of - ok -> + ok -> Limiter1; {disabled, Limiter2} -> ok = limit_queues(Limiter2, State), @@ -1078,7 +1078,7 @@ handle_method(#'confirm.select'{nowait = NoWait}, _, State) -> handle_method(#'channel.flow'{active = true}, _, State = #ch{limiter = Limiter}) -> Limiter2 = case rabbit_limiter:unblock(Limiter) of - ok -> + ok -> Limiter; {disabled, Limiter1} -> ok = limit_queues(Limiter1, State), @@ -1307,13 +1307,13 @@ consumer_queues(Consumers) -> notify_limiter(Limiter, Acked) -> case rabbit_limiter:is_enabled(Limiter) of false -> ok; - true -> - case rabbit_misc:queue_fold(fun ({_, none, _}, Acc) -> Acc; - ({_, _, _}, Acc) -> Acc + 1 - end, 0, Acked) of - 0 -> ok; - Count -> rabbit_limiter:ack(Limiter, Count) - end + true -> case rabbit_misc:queue_fold( + fun ({_, none, _}, Acc) -> Acc; + ({_, _, _}, Acc) -> Acc + 1 + end, 0, Acked) of + 0 -> ok; + Count -> rabbit_limiter:ack(Limiter, Count) + end end. deliver_to_queues({Delivery = #delivery{message = Message = #basic_message{ |