diff --git a/apps/devops/app/providers/message_queue.py b/apps/devops/app/providers/message_queue.py
index 978e232..61e5c23 100644
--- a/apps/devops/app/providers/message_queue.py
+++ b/apps/devops/app/providers/message_queue.py
@@ -15,7 +15,7 @@ def register(app):
         try:
             # Initialize services during startup to avoid blocking app initialization
             print("🔧 Initializing services...")
-            app.deployment_heartbeat_subscriber = AsyncMQSubscriber("devops_reconcile_heartbeat")
+            app.deployment_heartbeat_subscriber = AsyncMQSubscriber("reconciler.output")
             app.deployment_status_service = DeploymentStatusUpdateService()
             print("✅ Services initialized")