diff --git a/apps/devops/app/providers/message_queue.py b/apps/devops/app/providers/message_queue.py
index 61e5c23..b2d87cb 100644
--- a/apps/devops/app/providers/message_queue.py
+++ b/apps/devops/app/providers/message_queue.py
@@ -1,4 +1,5 @@
 import asyncio
+import os
 from app.backend.infra.rabbitmq.async_subscriber import AsyncMQSubscriber
 from app.backend.services.deployment_status_update_service import DeploymentStatusUpdateService
 
@@ -15,7 +16,9 @@ def register(app):
         try:
             # Initialize services during startup to avoid blocking app initialization
             print("🔧 Initializing services...")
-            app.deployment_heartbeat_subscriber = AsyncMQSubscriber("reconciler.output")
+            output_queue_name = os.getenv("RABBITMQ_OUTPUT_QUEUE_NAME", "freeleaps.devops.reconciler.output")
+            print(f"Using output queue: {output_queue_name}")
+            app.deployment_heartbeat_subscriber = AsyncMQSubscriber(output_queue_name)
             app.deployment_status_service = DeploymentStatusUpdateService()
             print("✅ Services initialized")