diff --git a/feeder/util/mqtt/client.py b/feeder/util/mqtt/client.py index b7de15df..c0baaa68 100644 --- a/feeder/util/mqtt/client.py +++ b/feeder/util/mqtt/client.py @@ -229,7 +229,7 @@ async def start(self): await self.connect( "mqtt://%s:%s@localhost:1883/" % (local_username, local_password) ) - await self.subscribe([("krs/tel/gts/#", QOS_2), ("krs/api/gts/#", QOS_2)]) + await self.subscribe([("#", QOS_2)]) try: while True: message = await self.deliver_message()