gmqtt
gmqtt copied to clipboard
wialon
Python MQTT v5.0 async client
If you run [properties example](https://github.com/wialon/gmqtt/blob/2fb5d6dec9ebbc902acfa63412f21f256315a1c8/examples/properties.py) with host that is not running broker (eg localhost), program will crash ``` Traceback (most recent call last): File "properties.py", line 98, in loop.run_until_complete(main('localhost', port,...
This PR provides a new revision of the sample code that has a few key features: * construct the gmqtt.Client() outside of the run loop * graceful shutdown of the...
i have an application with google-iot-core Google iot-core allows you to have A gateway with multiple devices The gateway is the Client. To be able the multiples devices to communicate...
Hi. We have such code (simplified): `client = MQTTClient(instance_name, session_expiry_interval=0, clean_session=True)` `await client.connect(broker_addr)` `client.publish("theMessage", qos=1, retain=True)` `# we possibly send here much more messages` `await asyncio.sleep(4) # wait for publish...
when there is keeplive in connack， the exception： result = self._handle_packet(cmd, packet) File "E:\workspace\mqtt-simulator\env\lib\site-packages\gmqtt\mqtt\handler.py", line 214, in _handle_packet handler(cmd, packet) File "E:\workspace\mqtt-simulator\env\lib\site-packages\gmqtt\mqtt\handler.py", line 286, in _handle_connack_packet File "E:\workspace\mqtt-simulator\env\lib\site-packages\gmqtt\mqtt\handler.py", line 257,...
I was looking for a way of checking if the reconnect_tries was exceeded and found this issue: https://github.com/wialon/gmqtt/issues/72 that was asking the same. It has a PR associated: https://github.com/wialon/gmqtt/pull/76 The...
Hi everyone I want to use ca.crt, client.crt, client.key to connect mqtt broker. My code like following: ``` client = MQTTClient(clientId) print("Before ", client.is_connected) contextInstance = ssl.SSLContext(ssl.PROTOCOL_TLSv1_2) contextInstance.load_default_certs() contextInstance.load_verify_locations(cafile=tls_CERT_PATH, cadata=None,...
I don't understand the code well enough to make sense of what I am seeing here, but I am sometimes getting exceptions thrown in MqttPackageHandler._handle_publish_packet() due to the returned value...
After the client automatically restores the connection with a broker it doesn't resubscribe and the broker also doesn't save subscriptions with `session_expire_interval` not set. So all subscriptions lost and the...
On sending messages/ack it is showing QoS query is full Is there any way to increase the max in IdGenerator from a client itself? Attaching the stack trace for more...
