We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8534dbc commit 6aa581fCopy full SHA for 6aa581f
hololinked/server/mqtt.py
@@ -93,6 +93,14 @@ async def start(self):
93
94
async def setup(self) -> None:
95
eventloop = get_current_async_loop()
96
+ for thing in self.things or []:
97
+ if not thing.rpc_server:
98
+ raise ValueError(f"Thing {thing.id} is not associated with any RPC server")
99
+ self.add_thing_instance_through_broker(
100
+ server_id=thing.rpc_server.id,
101
+ access_point="INPROC",
102
+ thing_id=thing.id,
103
+ )
104
for thing in self._broker_things:
105
thing, td = await consume_broker_queue(
106
id=f"{self.hostname}:{self.port}|mqtt-publisher|{uuid.uuid4().hex[:8]}",
0 commit comments