Skip to content

Commit

Permalink
Fix subscriptions with different qos
Browse files Browse the repository at this point in the history
Status was being used as a tuple, but it is a dict
  • Loading branch information
tlifschitz authored Jan 23, 2024
1 parent f29adc4 commit 38d78f6
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion mqttasgi/server.py
Original file line number Diff line number Diff line change
Expand Up @@ -203,7 +203,7 @@ async def mqtt_subscribe(self, app_id, msg):
"[mqttasgi][app][subscribe] - Subscription to {} must be updated to QOS: {}".format(topic, qos))
self.client.unsubscribe(topic)
self.client.subscribe(topic, qos)
status = (qos, status[1])
status = qos
elif len(status['apps']) == 0:
self.log.debug("[mqttasgi][app][subscribe] - Subscription to {}:{}".format(topic, qos))
self.client.message_callback_add(topic, lambda client, userdata,
Expand Down

0 comments on commit 38d78f6

Please sign in to comment.