summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2013-01-10 15:54:35 +0000
committerSimon MacMullen <simon@rabbitmq.com>2013-01-10 15:54:35 +0000
commitff143cf6d294182f19854cff564b7ecd76178033 (patch)
treef98100b6febeeab2bcd7f739299bcaffb54c6e89 /src
parent4014babf9c436b985a190baa5fc05ffc1db05783 (diff)
downloadrabbitmq-server-git-ff143cf6d294182f19854cff564b7ecd76178033.tar.gz
consumer_mapping changed since this branch was last worked on.
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_channel.erl10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index 6c2c37f9a8..a8df19ff01 100644
--- a/src/rabbit_channel.erl
+++ b/src/rabbit_channel.erl
@@ -1090,11 +1090,11 @@ handle_method(#'basic.credit'{consumer_tag = CTag,
%% want that? Because at least then it's consistent with the credit value
%% we return. And Available is always going to be racy.
Available = case dict:find(CTag, Consumers) of
- {ok, {Q, _}} -> case rabbit_amqqueue:stat(Q) of
- {ok, Len, _} -> Len;
- _ -> -1
- end;
- error -> -1 %% TODO these -1s smell very iffy!
+ {ok, Q} -> case rabbit_amqqueue:stat(Q) of
+ {ok, Len, _} -> Len;
+ _ -> -1
+ end;
+ error -> -1 %% TODO these -1s smell very iffy!
end,
Limiter1 = case rabbit_limiter:is_enabled(Limiter) of
true -> Limiter;