wait-for-rpc-exchange-creation

cloud-rocket · cloud-rocket · commit ea70cd43264f · 2025-06-25T15:03:36.000-05:00
diff --git a/src/amqp_fabric/amq_broker_connector.py b/src/amqp_fabric/amq_broker_connector.py
@@ -216,6 +216,8 @@ async def rpc_register(self, api):
             channel, auto_delete=True, exchange=self._rpc_server_exchange_name
         )
 
+        await aio.sleep(0.1)
+
         for api_name in dir(api):
             callee = getattr(api, api_name)
             if isinstance(callee, MethodType) and not api_name.startswith("_"):

Original file line number	Diff line number	Diff line change
`@@ -216,6 +216,8 @@ async def rpc_register(self, api):`
`216`	`216`	`channel, auto_delete=True, exchange=self._rpc_server_exchange_name`
`217`	`217`	`)`
`218`	`218`
	`219`	`+ await aio.sleep(0.1)`
	`220`	`+`
`219`	`221`	`for api_name in dir(api):`
`220`	`222`	`callee = getattr(api, api_name)`
`221`	`223`	`if isinstance(callee, MethodType) and not api_name.startswith("_"):`