drop retain in on_message

Author: jwcooper

Adafruit_IO/mqtt_client.py

@@ -91,8 +91,7 @@ def _mqtt_message(self, client, userdata, msg):
         if self.on_message is not None and self._username == parsed_topic[0]:
             feed = parsed_topic[2]
             payload = '' if msg.payload is None else msg.payload.decode('utf-8')
-            retain = msg.retain
-            self.on_message(self, feed, payload, retain)
+            self.on_message(self, feed, payload)
 
     def connect(self, **kwargs):
         """Connect to the Adafruit.IO service.  Must be called before any loop

CHANGELOG.md

@@ -1,6 +1,5 @@
 2.0.0
-- Drop support for API V1. Defaults to API V2.
-- Add retain flag option to mqtt on_message
+- Drop support for API V1. Defaults to API V2
 - Add support for Python3
 - New send_batch_data method
 

tests/test_mqtt_client.py

@@ -83,7 +83,7 @@ def test_subscribe_and_publish(self):
         client = MQTTClient(self.get_test_username(), self.get_test_key())
         # Save all on_message handler responses.
         messages = []
-        def on_message(mqtt_client, feed, payload, retain):
+        def on_message(mqtt_client, feed, payload):
             self.assertEqual(mqtt_client, client)
             messages.append((feed, payload))
         client.on_message = on_message