Skip to content

Commit 355ee7d

Browse files
author
Simon MacMullen
committed
TODO++
1 parent 4e60556 commit 355ee7d

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/rabbit_channel.erl

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -841,6 +841,8 @@ handle_method(#'basic.qos'{prefetch_count = 0}, _,
841841

842842
handle_method(#'basic.qos'{prefetch_count = PrefetchCount}, _,
843843
State = #ch{limiter = Limiter, unacked_message_q = UAMQ}) ->
844+
%% TODO queue:len(UAMQ) is not strictly right since that counts
845+
%% unacked messages from basic.get too. Pretty obscure though.
844846
Limiter1 = rabbit_limiter:limit_prefetch(Limiter,
845847
PrefetchCount, queue:len(UAMQ)),
846848
{reply, #'basic.qos_ok'{},

0 commit comments

Comments
 (0)