diff --git a/apps/devops/app/backend/infra/rabbitmq/async_client.py b/apps/devops/app/backend/infra/rabbitmq/async_client.py
index a48fc58..39e9f28 100644
--- a/apps/devops/app/backend/infra/rabbitmq/async_client.py
+++ b/apps/devops/app/backend/infra/rabbitmq/async_client.py
@@ -37,8 +37,10 @@ class AsyncMQClient:
                     name=self.exchange_name, type="direct", auto_delete=False
                 )
 
+                # Connect to existing named queue instead of creating anonymous queue
+                # channel_name already contains the full queue name from environment variable
                 self.queue = await self.channel.declare_queue(
-                    name=None, exclusive=True, auto_delete=True, durable=False
+                    name=self.channel_name, exclusive=False, auto_delete=False, durable=True
                 )
                 await self.queue.bind(
                     exchange=self.exchange, routing_key=self.routing_key