Update exchange name

Advayp · Advayp · commit 0a2dbd9422a9 · 2025-04-29T23:12:52.000-07:00
diff --git a/app/mq/consumers.py b/app/mq/consumers.py
@@ -21,7 +21,7 @@
 
 @mq_consumer(
   queue='ai.to-review-queue',
-  exchange='ai',
+  exchange='swecc-ai-exchange',
   routing_key='to-review'
 )
 async def consume_to_review_message(body, properties):
diff --git a/app/mq/producers.py b/app/mq/producers.py
@@ -2,7 +2,7 @@
 import json
 
 @mq_producer(
-    exchange='ai',
+    exchange='swecc-ai-exchange',
     routing_key='reviewed'
 )
 async def finish_review(data: dict):

Original file line number	Diff line number	Diff line change
`@@ -21,7 +21,7 @@`
`21`	`21`
`22`	`22`	`@mq_consumer(`
`23`	`23`	`queue='ai.to-review-queue',`
`24`		`- exchange='ai',`
	`24`	`+ exchange='swecc-ai-exchange',`
`25`	`25`	`routing_key='to-review'`
`26`	`26`	`)`
`27`	`27`	`async def consume_to_review_message(body, properties):`
Original file line number	Diff line number	Diff line change
`@@ -2,7 +2,7 @@`
`2`	`2`	`import json`
`3`	`3`
`4`	`4`	`@mq_producer(`
`5`		`- exchange='ai',`
	`5`	`+ exchange='swecc-ai-exchange',`
`6`	`6`	`routing_key='reviewed'`
`7`	`7`	`)`
`8`	`8`	`async def finish_review(data: dict):`