Update broker_thr.py

This commit is contained in:
ed 2026-03-07 21:49:36 +00:00 committed by GitHub
parent 7e8539c6ce
commit 157e7bcb3f
No known key found for this signature in database
GPG key ID: B5690EEEBB952194

View file

@ -53,17 +53,18 @@ class BrokerThr(BrokerCli):
return NotExQueue(obj(*args)) # type: ignore
def say(self, dest: str, *args: Any) -> None:
if dest == "httpsrv.listen":
self.httpsrv.listen(args[0], 1)
return
if dest.startswith("httpsrv."):
if dest == "httpsrv.listen":
self.httpsrv.listen(args[0], 1)
return
if dest == "httpsrv.set_netdevs":
self.httpsrv.set_netdevs(args[0])
return
if dest == "httpsrv.set_netdevs":
self.httpsrv.set_netdevs(args[0])
return
if dest == "httpsrv.set_bad_ver":
self.httpsrv.set_bad_ver(args[0])
return
if dest == "httpsrv.set_bad_ver":
self.httpsrv.set_bad_ver()
return
# new ipc invoking managed service in hub
obj = self.hub