diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-05-10 12:39:54 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-05-10 12:39:54 +0100 |
| commit | 355ee7dec9b7586ed37efc1a6328d10890da975f (patch) | |
| tree | b2930e6801d8cb9c2aabe7d92cf960184aab20fa | |
| parent | 4e60556fbd437e4fc0042124b259da16c92c354c (diff) | |
| download | rabbitmq-server-git-355ee7dec9b7586ed37efc1a6328d10890da975f.tar.gz | |
TODO++
| -rw-r--r-- | src/rabbit_channel.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 52c6140e2c..37041d346e 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -841,6 +841,8 @@ handle_method(#'basic.qos'{prefetch_count = 0}, _, handle_method(#'basic.qos'{prefetch_count = PrefetchCount}, _, State = #ch{limiter = Limiter, unacked_message_q = UAMQ}) -> + %% TODO queue:len(UAMQ) is not strictly right since that counts + %% unacked messages from basic.get too. Pretty obscure though. Limiter1 = rabbit_limiter:limit_prefetch(Limiter, PrefetchCount, queue:len(UAMQ)), {reply, #'basic.qos_ok'{}, |