From ae0dbc9500599cad81fd4e1bf9c51396c6e2b1a2 Mon Sep 17 00:00:00 2001 From: Simon MacMullen Date: Fri, 10 May 2013 12:39:54 +0100 Subject: TODO++ --- src/rabbit_channel.erl | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 52c6140e..37041d34 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'{}, -- cgit v1.2.1