We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5a4ad2b commit 0220f5cCopy full SHA for 0220f5c
consumer.py
@@ -131,7 +131,7 @@ def query_mqtt(config: MQTTClient):
131
132
client = config["client"]
133
if istypedinstance(client, FileClient):
134
- query_file(cast(FileClient, client))
+ query_file(cast(FileClient, client), receiver=receiver)
135
elif istypedinstance(client, MQTTClient):
136
client = query_mqtt(cast(MQTTClient, client))
137
client.loop_forever()
0 commit comments