Blame rabbitmq-0001-Ignore-unknown-channel-acks-in-queue.patch
|
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) ->
|