diff --git a/pyinfra/examples.py b/pyinfra/examples.py index b1f7f48..6ad1fa8 100644 --- a/pyinfra/examples.py +++ b/pyinfra/examples.py @@ -28,7 +28,7 @@ def get_rabbitmq_config(settings: Dynaconf): heartbeat=settings.rabbitmq.heartbeat, input_queue_prefix=settings.rabbitmq.service_request_queue_prefix, tenant_event_queue_suffix=settings.rabbitmq.tenant_event_queue_suffix, - tenant_exchange_name=settings.rabbitmq.service_response_queue_prefix, + tenant_exchange_name=settings.rabbitmq.tenant_exchange_name, service_request_exchange_name=settings.rabbitmq.service_request_exchange_name, service_response_exchange_name=settings.rabbitmq.service_response_exchange_name, service_dead_letter_queue_name=settings.rabbitmq.service_dlq_name, diff --git a/scripts/send_threaded_request.py b/scripts/send_threaded_request.py index ca9e2b9..6824838 100644 --- a/scripts/send_threaded_request.py +++ b/scripts/send_threaded_request.py @@ -57,7 +57,7 @@ def send_tenant_event(tenant_id: str, event_type: str): def send_service_request(tenant_id: str): queue_manager = ServiceQueueManager(settings) - queue_name = f"{settings.rabbitmq.service_response_queue_prefix}_{tenant_id}" + queue_name = f"service_response_queue_{tenant_id}" queue_manager.purge_queues()