diff options
| -rw-r--r-- | src/rabbit_queue_collector.erl | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/rabbit_queue_collector.erl b/src/rabbit_queue_collector.erl index e5215660..6ac402c8 100644 --- a/src/rabbit_queue_collector.erl +++ b/src/rabbit_queue_collector.erl @@ -93,11 +93,12 @@ handle_cast(Msg, State) -> handle_info({'DOWN', MonitorRef, process, _DownPid, _Reason}, State = #state{queues = Queues, delete_from = Deleting}) -> - case {Deleting, dict:size(Queues)} of - {undefined, _} -> ok; - {_, 1} -> gen_server:reply(Deleting, ok) + Queues1 = dict:erase(MonitorRef, Queues), + case Deleting =/= undefined andalso dict:size(Queues1) =:= 0 of + true -> gen_server:reply(Deleting, ok); + false -> ok end, - {noreply, State#state{queues = dict:erase(MonitorRef, Queues)}}. + {noreply, State#state{queues = Queues1}}. terminate(_Reason, _State) -> ok. |