summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlexandru Scvortov <alexandru@rabbitmq.com>2011-07-26 16:17:38 +0100
committerAlexandru Scvortov <alexandru@rabbitmq.com>2011-07-26 16:17:38 +0100
commitbdf102c7b44dca971fced0dfe75fa2a09b07f06b (patch)
treef90e4ae629e86ba7f5b1a83030813b9bbad1bbb1
parent9d7b2f212b0ce1daa03f9595e85134c72f839cbc (diff)
downloadrabbitmq-server-bdf102c7b44dca971fced0dfe75fa2a09b07f06b.tar.gz
cosmetic
Not sure how the misaligned -> happened..
-rw-r--r--src/rabbit_channel.erl18
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{