removed old fixed queues

openrightsgroup · Mar 20, 2022 · 5e52b98 · 5e52b98
1 parent d1e9d60
commit 5e52b98
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/api/1.2/libs/queue.php b/api/1.2/libs/queue.php
@@ -93,9 +93,10 @@ public function setup_isp_queues() {
             }
 
         	$this->delete_queue('url.'.$isp['queue_name'].'.ooni');
+        	$this->delete_queue('url.'.$isp['queue_name'].'.fixed');
 
             if ($isp['isp_type'] == 'fixed') {
-                $this->createqueue('url.'.$isp['queue_name'].'.fixed', 'url.fixed', AMQP_PUBLIC_QUEUE_TIMEOUT, true);
+                $this->createqueue('url.'.$isp['queue_name'].'.public', 'url.fixed', AMQP_PUBLIC_QUEUE_TIMEOUT, true);
             }
 
             #createqueue('admin.view.' . $isp['queue_name'], 'admin.view.#');