Specify CallbackAPIVersion.VERSION1

Author: tyeth

Adafruit_IO/mqtt_client.py

@@ -60,7 +60,7 @@ def __init__(self, username, key, service_host='io.adafruit.com', secure=True):
         self.on_message    = None
         self.on_subscribe  = None
         # Initialize MQTT client.
-        self._client = mqtt.Client()
+        self._client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION1)
         if secure:
             self._client.tls_set_context()
             self._secure = True

examples/mqtt/mqtt_viewall.py

@@ -50,12 +50,12 @@ def on_connect(client, userdata, flags, rc):
 def on_disconnect(client, userdata, rc):
     print('Disconnected!')
 
-def on_message(client, userdata, msg, retain):
+def on_message(client, userdata, msg):
     print('Received on {0}: {1}'.format(msg.topic, msg.payload.decode('utf-8')))
 
 
 # Create MQTT client and connect to Adafruit IO.
-client = mqtt.Client()
+client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION1)
 client.username_pw_set(USERNAME, KEY)
 client.on_connect = on_connect
 client.on_disconnect = on_disconnect