summaryrefslogtreecommitdiff
path: root/src/rabbit_channel.erl
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2013-01-15 18:50:56 +0000
committerMatthias Radestock <matthias@rabbitmq.com>2013-01-15 18:50:56 +0000
commit097182274da2cd2d5a37ac35f6add7d06963ba76 (patch)
tree526e2a46a7b523342e09c74d54a88ec8034ea4b5 /src/rabbit_channel.erl
parent2ad15707cb8ccf7c192fb619b4bdb5032fd40b9c (diff)
downloadrabbitmq-server-097182274da2cd2d5a37ac35f6add7d06963ba76.tar.gz
API consistency
Diffstat (limited to 'src/rabbit_channel.erl')
-rw-r--r--src/rabbit_channel.erl2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index 2bc2db83..8d916703 100644
--- a/src/rabbit_channel.erl
+++ b/src/rabbit_channel.erl
@@ -1100,7 +1100,7 @@ handle_method(#'basic.credit'{consumer_tag = CTag,
credit_map = CMap}) ->
case dict:find(CTag, Consumers) of
{ok, Q} -> ok = rabbit_amqqueue:inform_limiter(
- self(), Q#amqqueue.pid,
+ Q, self(),
{basic_credit, CTag, Credit, Count, Drain, true}),
{noreply, State};
error -> CMap2 = dict:store(CTag, {Credit, Count, Drain}, CMap),