diff options
| author | Simon MacMullen <simon@lshift.net> | 2010-05-20 16:11:44 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@lshift.net> | 2010-05-20 16:11:44 +0100 |
| commit | bb58efaff44c4bb39f00eb1f591b8baa979ee2cd (patch) | |
| tree | a4a3878167d58820ae325fd80b904a9a616fcb70 | |
| parent | 58cd29086433c4b55c08d4d96ec22a1095a416aa (diff) | |
| download | rabbitmq-server-bb58efaff44c4bb39f00eb1f591b8baa979ee2cd.tar.gz | |
No reason for this to be a dict of lists.
| -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 6c86cab8..058affa7 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) -> |