diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_limiter.erl | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/src/rabbit_limiter.erl b/src/rabbit_limiter.erl index 6cc170f90f..0d938580f9 100644 --- a/src/rabbit_limiter.erl +++ b/src/rabbit_limiter.erl @@ -144,8 +144,11 @@ code_change(_, State, _) -> % Starts to monitor a particular queue monitor_queue(QPid, State = #lim{queues = Queues}) -> - MonitorRef = erlang:monitor(process, QPid), - State#lim{queues = dict:store(QPid, MonitorRef, Queues)}. + case dict:is_key(QPid, Queues) of + false -> MonitorRef = erlang:monitor(process, QPid), + State#lim{queues = dict:store(QPid, MonitorRef, Queues)}; + true -> State + end. % Stops monitoring a particular queue demonitor_queue(QPid, State = #lim{queues = Queues}) -> |