diff options
| -rw-r--r-- | src/rabbit_queue_consumers.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_queue_consumers.erl b/src/rabbit_queue_consumers.erl index 549e0ffa39..f94bd46c71 100644 --- a/src/rabbit_queue_consumers.erl +++ b/src/rabbit_queue_consumers.erl @@ -116,7 +116,7 @@ record_ack(ChPid, LimiterPid, AckTag) -> C = #cr{acktags = ChAckTags} = ch_record(ChPid, LimiterPid), update_ch_record(C#cr{acktags = queue:in(AckTag, ChAckTags)}), ok. - + subtract_acks(ChPid, AckTags) -> case lookup_ch(ChPid) of not_found -> |