Skip to content

Commit 2d536f4

Browse files
Backport #496 to 3.5.x
1 parent 46b54ff commit 2d536f4

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/rabbit_queue_consumers.erl

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -279,7 +279,9 @@ subtract_acks([T | TL] = AckTags, Prefix, CTagCounts, AckQ) ->
279279
subtract_acks(TL, Prefix,
280280
orddict:update_counter(CTag, 1, CTagCounts), QTail);
281281
{{value, V}, QTail} ->
282-
subtract_acks(AckTags, [V | Prefix], CTagCounts, QTail)
282+
subtract_acks(AckTags, [V | Prefix], CTagCounts, QTail);
283+
{empty, _} ->
284+
subtract_acks([], Prefix, CTagCounts, AckQ)
283285
end.
284286

285287
possibly_unblock(Update, ChPid, State) ->

0 commit comments

Comments
 (0)