Skip to content

Commit fec1a57

Browse files
committed
Added check for incoming properties in CONACK
1 parent 7f8772a commit fec1a57

File tree

1 file changed

+7
-5
lines changed

1 file changed

+7
-5
lines changed

tb_device_mqtt.py

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -600,11 +600,13 @@ def _on_connect(self, client, userdata, connect_flags, result_code, properties,
600600
log.info("MQTT client %r - Connected!", client)
601601
if properties:
602602
log.debug("MQTT client %r - CONACK Properties: %r", client, properties)
603-
config = {
604-
"maxPayloadSize": int(properties.MaximumPacketSize * DEFAULT_RATE_LIMIT_PERCENTAGE / 100),
605-
"maxInflightMessages": properties.ReceiveMaximum,
606-
}
607-
self.on_service_configuration(None, config)
603+
config = {}
604+
if hasattr(properties, 'MaximumPacketSize'):
605+
config['maxPayloadSize'] = int(properties.MaximumPacketSize * DEFAULT_RATE_LIMIT_PERCENTAGE / 100)
606+
if hasattr(properties, 'ReceiveMaximum'):
607+
config['maxInflightMessages'] = properties.ReceiveMaximum
608+
if config:
609+
self.on_service_configuration(None, config)
608610
self._subscribe_to_topic(ATTRIBUTES_TOPIC, qos=self.quality_of_service)
609611
self._subscribe_to_topic(ATTRIBUTES_TOPIC + "/response/+", qos=self.quality_of_service)
610612
self._subscribe_to_topic(RPC_REQUEST_TOPIC + '+', qos=self.quality_of_service)

0 commit comments

Comments
 (0)