diff options
| author | Ben Hood <0x6e6562@gmail.com> | 2008-12-18 17:26:56 +0000 |
|---|---|---|
| committer | Ben Hood <0x6e6562@gmail.com> | 2008-12-18 17:26:56 +0000 |
| commit | c0f9c53586bf0876e135410876b813bee5476993 (patch) | |
| tree | 9587b6202ab9ee7b7a07777fe23495657ff5d15c /src | |
| parent | a9d788d7694fb39332934255372f2efc40cad62b (diff) | |
| download | rabbitmq-server-git-c0f9c53586bf0876e135410876b813bee5476993.tar.gz | |
Fix for multi ack bug
Diffstat (limited to 'src')
| -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 d91893b0e8..20f543599a 100644 --- a/src/rabbit_limiter.erl +++ b/src/rabbit_limiter.erl @@ -131,7 +131,7 @@ handle_cast({decrement_capacity, Magnitude}, State = #lim{in_use = InUse}) -> if ShouldNotify -> notify_queues(State), - {noreply, State#lim{queues = sets:new(), in_use = InUse - 1}}; + {noreply, State#lim{queues = sets:new(), in_use = InUse - Magnitude}}; true -> {noreply, NewState} end. |