fix: raise error if new_inbox() is called before broker was started

airtai · Jun 20, 2024 · 3e90aa4 · 3e90aa4
1 parent 7b92dd1
commit 3e90aa4
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/faststream/nats/broker/broker.py b/faststream/nats/broker/broker.py
@@ -909,4 +909,7 @@ async def new_inbox(self) -> str:
 
         [1] https://nats-io.github.io/nats.py/modules.html#nats.aio.client.Client.new_inbox
         """
+        if not self._connection:
+            raise RuntimeError("Broker needs to be started before calling this method.")
+
         return self._connection.new_inbox()