Fix typo.

Thanks to Jan Nijs.

diff --git a/setup.py b/setup.py
index 80e58000916442bc970381d52b8c308461b40ded..20a233fc7ddbe70b4f65d030502ffe647761aa1d 100644 (file)
--- a/setup.py
+++ b/setup.py
@@ -2,7 +2,7 @@ from sys import version
 
 from distutils.core import setup
 setup(name='paho-mqtt',
-       version='0.4.90',
+       version='0.4.91',
        description='MQTT version 3.1 client class',
        author='Roger Light',
        author_email='roger@atchoo.org',

diff --git a/src/paho/mqtt/client.py b/src/paho/mqtt/client.py
index a6da14f606248104278a6f666a2fe69b9c45c7b4..da188be2a9ffaed17fb98ed8001912e933978b37 100755 (executable)
--- a/src/paho/mqtt/client.py
+++ b/src/paho/mqtt/client.py
@@ -1155,7 +1155,7 @@ class Client(object):
                     rc = 1
                     run = False
 
-            self._state_mutex_acquire()
+            self._state_mutex.acquire()
             if self._state == mqtt_cs_disconnecting:
                 run = False
                 self._state_mutex.release()