Skip to content

Commit 75a84c5

Browse files
authored
Merge pull request #22 from mikeadamz/retain_flag
Pass 'retain' flag from paho MQTT to on_message callback
2 parents 3d79f01 + 24ae5bb commit 75a84c5

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

Adafruit_IO/mqtt_client.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,8 @@ def _mqtt_message(self, client, userdata, msg):
9191
if self.on_message is not None and self._username == parsed_topic[0]:
9292
feed = parsed_topic[2]
9393
payload = '' if msg.payload is None else msg.payload.decode('utf-8')
94-
self.on_message(self, feed, payload)
94+
retain = msg.retain
95+
self.on_message(self, feed, payload, retain)
9596

9697
def connect(self, **kwargs):
9798
"""Connect to the Adafruit.IO service. Must be called before any loop

0 commit comments

Comments
 (0)