diff options
| -rw-r--r-- | src/rabbit_queue_consumers.erl | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/rabbit_queue_consumers.erl b/src/rabbit_queue_consumers.erl index 3ba9f89205..29fc74dc52 100644 --- a/src/rabbit_queue_consumers.erl +++ b/src/rabbit_queue_consumers.erl @@ -281,7 +281,9 @@ subtract_acks([T | TL] = AckTags, Prefix, CTagCounts, AckQ) -> subtract_acks(TL, Prefix, orddict:update_counter(CTag, 1, CTagCounts), QTail); {{value, V}, QTail} -> - subtract_acks(AckTags, [V | Prefix], CTagCounts, QTail) + subtract_acks(AckTags, [V | Prefix], CTagCounts, QTail); + {empty, _} -> + subtract_acks([], Prefix, CTagCounts, AckQ) end. possibly_unblock(Update, ChPid, State) -> |