Skip to content

Commit a6f591d

Browse files
committed
Fix channel rate limiter for ack messages
1 parent 23432f3 commit a6f591d

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

deps/rabbit/src/rabbit_channel.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2121,13 +2121,13 @@ notify_limiter(Limiter, Acked) ->
21212121
%% common case.
21222122
case rabbit_limiter:is_active(Limiter) of
21232123
false -> ok;
2124-
true -> case lists:foldl(fun ({_, CTag, _, _}, Acc) when is_integer(CTag) ->
2124+
true -> case lists:foldl(fun (#pending_ack{tag = CTag}, Acc) when is_integer(CTag) ->
21252125
%% Quorum queues use integer CTags
21262126
%% classic queues use binaries
21272127
%% Quorum queues do not interact
21282128
%% with limiters
21292129
Acc;
2130-
({_, _, _, _}, Acc) -> Acc + 1
2130+
(_, Acc) -> Acc + 1
21312131
end, 0, Acked) of
21322132
0 -> ok;
21332133
Count -> rabbit_limiter:ack(Limiter, Count)

0 commit comments

Comments
 (0)