diff --git a/pyinfra/examples.py b/pyinfra/examples.py
index 4440bac..b643e8b 100644
--- a/pyinfra/examples.py
+++ b/pyinfra/examples.py
@@ -37,8 +37,8 @@ def start_standard_queue_consumer(
 
     app = app or FastAPI()
 
-    # tenant_manager = TenantQueueManager(settings)
-    # service_manager = ServiceQueueManager(settings)
+    tenant_manager = TenantQueueManager(settings)
+    service_manager = ServiceQueueManager(settings)
 
     if settings.metrics.prometheus.enabled:
         logger.info("Prometheus metrics enabled.")
@@ -51,21 +51,21 @@ def start_standard_queue_consumer(
         instrument_pika()
         instrument_app(app)
 
-    manager = AsyncQueueManager(settings=settings, message_processor=callback)
+    # manager = AsyncQueueManager(settings=settings, message_processor=callback)
 
-    # app = add_health_check_endpoint(app, service_manager.is_ready)
-    app = add_health_check_endpoint(app, manager.is_ready)
+    app = add_health_check_endpoint(app, service_manager.is_ready)
+    # app = add_health_check_endpoint(app, manager.is_ready)
 
     webserver_thread = create_webserver_thread_from_settings(app, settings)
     webserver_thread.start()
 
-    # thread_t = Thread(target=tenant_manager.start_consuming, daemon=True)
-    # thread_s = Thread(target=service_manager.start_sequential_basic_get, args=(callback,), daemon=True)
+    thread_t = Thread(target=tenant_manager.start_consuming, daemon=True)
+    thread_s = Thread(target=service_manager.start_sequential_basic_get, args=(callback,), daemon=True)
 
-    # thread_t.start()
-    # thread_s.start()
+    thread_t.start()
+    thread_s.start()
 
-    # thread_t.join()
-    # thread_s.join()
+    thread_t.join()
+    thread_s.join()
     
-    asyncio.run(manager.start_processing())
\ No newline at end of file
+    # asyncio.run(manager.start_processing())
\ No newline at end of file
diff --git a/pyinfra/queue/threaded_tenants.py b/pyinfra/queue/threaded_tenants.py
index cbf1e25..55eea3e 100644
--- a/pyinfra/queue/threaded_tenants.py
+++ b/pyinfra/queue/threaded_tenants.py
@@ -312,7 +312,7 @@ class ServiceQueueManager(BaseQueueManager):
                         on_message_callback = self._make_on_message_callback(message_processor, tenant_id)
                         on_message_callback(self.channel, method_frame, properties, body)
                     else:
-                        logger.debug(f"No message returned for queue {queue_name}")
+                        # logger.debug(f"No message returned for queue {queue_name}")
                         # time.sleep(self.connection_sleep)
                         time.sleep(0.1)