fixup! use pagination to get all queues. Make checking for which queu…

…es to delete much quicker by reading .queue files instead of computing SHA1 where possible
cloudamqp · Jan 10, 2025 · 7538f3c · 7538f3c
1 parent 1dbef7e
commit 7538f3c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/lavinmqctl.cr b/src/lavinmqctl.cr
@@ -717,10 +717,10 @@ class LavinMQCtl
       rescue e : File::NotFoundError
       end
 
-      queues = get("/api/queues/#{URI.encode_www_form(current_vhost)}","name")
+      queues = get("/api/queues/#{URI.encode_www_form(current_vhost)}", "name")
 
       Dir.glob("#{vhost_data_dir}/*/.queue").each do |dir|
-        queues.delete({ "name"=> File.read(dir) })
+        queues.delete({"name" => File.read(dir)})
         queue_dirs.delete(dir[0..-8])
       end