diff options
| author | Michael Klishin <mklishin@pivotal.io> | 2015-12-15 00:58:10 +0300 |
|---|---|---|
| committer | Michael Klishin <mklishin@pivotal.io> | 2015-12-15 00:58:10 +0300 |
| commit | 2d536f4f688f656adcea63e7706021da05190f60 (patch) | |
| tree | a98512e278153ceb6bc1662065ec9e2910016fd5 | |
| parent | 46b54ff9efb00796def74e3a423b81a2d90dd151 (diff) | |
| download | rabbitmq-server-git-2d536f4f688f656adcea63e7706021da05190f60.tar.gz | |
Backport #496 to 3.5.x
| -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 ae8481aaf8..cdb2bff4a9 100644 --- a/src/rabbit_queue_consumers.erl +++ b/src/rabbit_queue_consumers.erl @@ -279,7 +279,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) -> |