diff --git a/apps/devops/app/providers/message_queue.py b/apps/devops/app/providers/message_queue.py
index 03ecb00..b272db4 100644
--- a/apps/devops/app/providers/message_queue.py
+++ b/apps/devops/app/providers/message_queue.py
@@ -10,21 +10,27 @@ def register(app):
     
     @app.on_event("startup")
     async def start_message_consumers():
+        print("Starting message consumers")
         # Register the heartbeat processor
         await app.deployment_heartbeat_subscriber.register_consumer(
             registry_key="deployment_heartbeat_processor",
             callback_method=app.deployment_status_service.process_heartbeat_message,
             args={}
         )
+        print("Registered deployment heartbeat processor")
         
         # Start the subscriber
         loop = asyncio.get_running_loop()
         await loop.create_task(
             app.deployment_heartbeat_subscriber.subscribe(max_retries=5, event_loop=loop)
         )
+        print("Started deployment heartbeat subscriber")
 
     @app.on_event("shutdown")
     async def stop_message_consumers():
         # Clear consumers and close connection
+        print("Stopping message consumers")
         await app.deployment_heartbeat_subscriber.clear_all_consumers()
-        await app.deployment_heartbeat_subscriber.close()
\ No newline at end of file
+        print("Cleared all consumers")
+        await app.deployment_heartbeat_subscriber.close()
+        print("Closed deployment heartbeat subscriber")
\ No newline at end of file