Peter Lemenkov d370f72
From: Daniil Fedotov <dfedotov@pivotal.io>
Peter Lemenkov d370f72
Date: Mon, 14 Dec 2015 16:01:24 +0000
Peter Lemenkov d370f72
Subject: [PATCH] Ignore unknown channel acks in queue
Peter Lemenkov d370f72
Peter Lemenkov d370f72
Peter Lemenkov d370f72
diff --git a/src/rabbit_queue_consumers.erl b/src/rabbit_queue_consumers.erl
Peter Lemenkov d370f72
index 4b1f07d..7c5bbba 100644
Peter Lemenkov d370f72
--- a/src/rabbit_queue_consumers.erl
Peter Lemenkov d370f72
+++ b/src/rabbit_queue_consumers.erl
Peter Lemenkov d370f72
@@ -276,7 +276,9 @@ subtract_acks([T | TL] = AckTags, Prefix, CTagCounts, AckQ) ->
Peter Lemenkov d370f72
             subtract_acks(TL, Prefix,
Peter Lemenkov d370f72
                           orddict:update_counter(CTag, 1, CTagCounts), QTail);
Peter Lemenkov d370f72
         {{value, V}, QTail} ->
Peter Lemenkov d370f72
-            subtract_acks(AckTags, [V | Prefix], CTagCounts, QTail)
Peter Lemenkov d370f72
+            subtract_acks(AckTags, [V | Prefix], CTagCounts, QTail);
Peter Lemenkov d370f72
+        {empty, _} -> 
Peter Lemenkov d370f72
+            subtract_acks([], Prefix, CTagCounts, AckQ)
Peter Lemenkov d370f72
     end.
Peter Lemenkov d370f72
 
Peter Lemenkov d370f72
 possibly_unblock(Update, ChPid, State) ->