diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_reader_queue_collector.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_reader_queue_collector.erl b/src/rabbit_reader_queue_collector.erl index 6c86cab880..058affa7d7 100644 --- a/src/rabbit_reader_queue_collector.erl +++ b/src/rabbit_reader_queue_collector.erl @@ -77,7 +77,7 @@ handle_call({register_exclusive_queue, Q}, _From, State = #state{exclusive_queues = Queues}) -> MonitorRef = erlang:monitor(process, Q#amqqueue.pid), {reply, ok, - State#state{exclusive_queues = dict:append(MonitorRef, Q, Queues)}}; + State#state{exclusive_queues = dict:store(MonitorRef, Q, Queues)}}; handle_call(delete_all, _From, State = #state{exclusive_queues = ExclusiveQueues}) -> @@ -87,7 +87,7 @@ handle_call(delete_all, _From, erlang:demonitor(MonitorRef), rabbit_amqqueue:delete(Q, false, false) end) - || {MonitorRef, [Q]} <- dict:to_list(ExclusiveQueues)], + || {MonitorRef, Q} <- dict:to_list(ExclusiveQueues)], {reply, ok, State}; handle_call(shutdown, _From, State) -> |