diff --git a/pyinfra/examples.py b/pyinfra/examples.py
index 199a9cf..9c21d9e 100644
--- a/pyinfra/examples.py
+++ b/pyinfra/examples.py
@@ -4,12 +4,9 @@ from dynaconf import Dynaconf
 from fastapi import FastAPI
 from kn_utils.logging import logger
 
-# from threading import Thread
 from pyinfra.config.loader import get_pyinfra_validators, validate_settings
 from pyinfra.queue.async_tenants_v2 import RabbitMQConfig, RabbitMQHandler
 from pyinfra.queue.callback import Callback
-
-# from pyinfra.queue.threaded_tenants import ServiceQueueManager, TenantQueueManager
 from pyinfra.queue.manager import QueueManager
 from pyinfra.utils.opentelemetry import instrument_app, instrument_pika, setup_trace
 from pyinfra.webserver.prometheus import (
@@ -56,9 +53,6 @@ def start_standard_queue_consumer(
 
     app = app or FastAPI()
 
-    # tenant_manager = TenantQueueManager(settings)
-    # service_manager = ServiceQueueManager(settings)
-
     if settings.metrics.prometheus.enabled:
         logger.info("Prometheus metrics enabled.")
         app = add_prometheus_endpoint(app)
@@ -70,7 +64,7 @@ def start_standard_queue_consumer(
         instrument_pika()
         instrument_app(app)
 
-    if settings.multiple_tenants.enabled:
+    if settings.concurrency.enabled:
         config = get_rabbitmq_config(settings)
         manager = RabbitMQHandler(
             config=config, tenant_service_url=settings.storage.tenant_server.endpoint, message_processor=callback