diff --git a/comfy/distributed/distributed_prompt_queue.py b/comfy/distributed/distributed_prompt_queue.py
index 91613db00..ad9a19fde 100644
--- a/comfy/distributed/distributed_prompt_queue.py
+++ b/comfy/distributed/distributed_prompt_queue.py
@@ -273,7 +273,7 @@ class DistributedPromptQueue(AbstractPromptQueue):
             return
         self._connection = await connect_robust(self._connection_uri, loop=self._loop)
         self._channel = await self._connection.channel()
-        self._rpc = await JsonRPC.create(channel=self._channel)
+        self._rpc = await JsonRPC.create(channel=self._channel, auto_delete=True, durable=False, exclusive=True)
         self._rpc.host_exceptions = True
         if self._is_caller:
             self._caller_progress_handlers = ProgressHandlers(self._rpc, self._caller_server, self._queue_name)