diff --git a/pyinfra/queue/threaded_tenants.py b/pyinfra/queue/threaded_tenants.py
index 9a00de4..a18e66f 100644
--- a/pyinfra/queue/threaded_tenants.py
+++ b/pyinfra/queue/threaded_tenants.py
@@ -257,8 +257,8 @@ class ServiceQueueManager(BaseQueueManager):
         self.tenant_ids = self.get_initial_tenant_ids(tenant_endpoint_url=settings.storage.tenant_server.endpoint)
 
     def initialize_queues(self) -> None:
-        self.channel.exchange_declare(exchange=self.service_request_exchange_name, exchange_type="direct")
-        self.channel.exchange_declare(exchange=self.service_response_exchange_name, exchange_type="direct")
+        self.channel.exchange_declare(exchange=self.service_request_exchange_name, exchange_type="direct", durable=True)
+        self.channel.exchange_declare(exchange=self.service_response_exchange_name, exchange_type="direct", durable=True)
 
         for tenant_id in self.tenant_ids:
             request_queue_name = f"{self.service_request_queue_prefix}_{tenant_id}"