Merge pull request #188 from ionutab/master

MqttClient does not have the protocol property
SvenskaSpel · Jul 12, 2024 · e9fb76d · e9fb76d
2 parents 260e6cc + 5c1a3ae
commit e9fb76d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/locust_plugins/users/mqtt.py b/locust_plugins/users/mqtt.py
@@ -118,7 +118,7 @@ def __init__(
         self.on_publish = self._on_publish_cb
         self.on_subscribe = self._on_subscribe_cb
 
-        if self.protocol == mqtt.MQTTv5:
+        if protocol == mqtt.MQTTv5:
             self.on_disconnect = self._on_disconnect_cb_v5
             self.on_connect = self._on_connect_cb_v5
         else: