diff options
| -rw-r--r-- | src/rabbit_limiter.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_limiter.erl b/src/rabbit_limiter.erl index a28c4a2f7d..5776fc3f7a 100644 --- a/src/rabbit_limiter.erl +++ b/src/rabbit_limiter.erl @@ -279,7 +279,7 @@ ack_from_queue(Limiter = #qstate{credits = Credits}, CTag, Credit) -> case gb_trees:lookup(CTag, Credits) of {value, C = #credit{mode = auto, credit = C0}} -> {update_credit(CTag, C#credit{credit = C0 + Credit}, Credits), - C0 =:= 0}; + C0 =:= 0 andalso Credit =/= 0}; _ -> {Credits, false} end, |
