diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-07-26 13:21:18 +0100 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-07-26 13:21:18 +0100 |
| commit | 08aff2a628cb92a891e7e600d5420e207595be8e (patch) | |
| tree | b476a3655723cf4d5e321160eb409ed296e221d8 /src/rabbit_amqqueue.erl | |
| parent | 0b7b63210106ce366c8f422d581087b9a75d835a (diff) | |
| download | rabbitmq-server-08aff2a628cb92a891e7e600d5420e207595be8e.tar.gz | |
finish refactoring
Diffstat (limited to 'src/rabbit_amqqueue.erl')
| -rw-r--r-- | src/rabbit_amqqueue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 0821b121..f44f5fec 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -440,10 +440,10 @@ notify_down_all(QPids, ChPid) -> fun (QPid) -> gen_server2:call(QPid, {notify_down, ChPid}, infinity) end, QPids). -limit_all(QPids, ChPid, LimiterToken) -> +limit_all(QPids, ChPid, Limiter) -> delegate:invoke_no_result( QPids, fun (QPid) -> - gen_server2:cast(QPid, {limit, ChPid, LimiterToken}) + gen_server2:cast(QPid, {limit, ChPid, Limiter}) end). basic_get(#amqqueue{pid = QPid}, ChPid, NoAck) -> |