diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-01-10 15:54:35 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-01-10 15:54:35 +0000 |
| commit | ff143cf6d294182f19854cff564b7ecd76178033 (patch) | |
| tree | f98100b6febeeab2bcd7f739299bcaffb54c6e89 /src | |
| parent | 4014babf9c436b985a190baa5fc05ffc1db05783 (diff) | |
| download | rabbitmq-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.erl | 10 |
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; |
