diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2013-12-23 20:26:10 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2013-12-23 20:26:10 +0000 |
| commit | 00ed34bc626f7135fe90a5e30754269da3f3e69f (patch) | |
| tree | db692e0e967994440248c3e5db5093162da92010 | |
| parent | 8e4a15d5ba40deeb1f138e657b342b48e35548bb (diff) | |
| download | rabbitmq-server-git-00ed34bc626f7135fe90a5e30754269da3f3e69f.tar.gz | |
cosmetic
| -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 -> |