Blob Blame History Raw
From: Daniil Fedotov <dfedotov@pivotal.io>
Date: Mon, 14 Dec 2015 16:01:24 +0000
Subject: [PATCH] Ignore unknown channel acks in queue


diff --git a/src/rabbit_queue_consumers.erl b/src/rabbit_queue_consumers.erl
index 4b1f07d..7c5bbba 100644
--- a/src/rabbit_queue_consumers.erl
+++ b/src/rabbit_queue_consumers.erl
@@ -276,7 +276,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) ->