summaryrefslogtreecommitdiff
path: root/src/rabbit_queue_collector.erl
diff options
context:
space:
mode:
authorAlexandru Scvortov <alexandru@rabbitmq.com>2010-09-28 08:24:24 +0100
committerAlexandru Scvortov <alexandru@rabbitmq.com>2010-09-28 08:24:24 +0100
commit17c51b5b022cf2d74c01d11a74b7a3917406ecdc (patch)
tree567861bac77ccf59b2f1c1767c440c3b01d894cc /src/rabbit_queue_collector.erl
parent6f2b51a33a91e193de6781c27d25810cc4f035f4 (diff)
downloadrabbitmq-server-17c51b5b022cf2d74c01d11a74b7a3917406ecdc.tar.gz
delete/1 -> delete_exclusive/1; lower priorities to 8
Diffstat (limited to 'src/rabbit_queue_collector.erl')
-rw-r--r--src/rabbit_queue_collector.erl2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_queue_collector.erl b/src/rabbit_queue_collector.erl
index 226ce186..99cb186e 100644
--- a/src/rabbit_queue_collector.erl
+++ b/src/rabbit_queue_collector.erl
@@ -85,7 +85,7 @@ handle_call(delete_all, _From, State = #state{queues = Queues}) ->
fun () -> ok end,
fun () ->
erlang:demonitor(MonitorRef),
- rabbit_amqqueue:delete(Q)
+ rabbit_amqqueue:delete_exclusive(Q)
end)
|| {MonitorRef, Q} <- dict:to_list(Queues)],
{reply, ok, State}.