Skip to content

Commit f115ab5

Browse files
committed
add retain flag to mqtt example scripts
1 parent 4b7456c commit f115ab5

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

examples/mqtt_client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ def disconnected(client):
3131
print('Disconnected from Adafruit IO!')
3232
sys.exit(1)
3333

34-
def message(client, feed_id, payload):
34+
def message(client, feed_id, payload, retain):
3535
# Message function will be called when a subscribed feed has a new value.
3636
# The feed_id parameter identifies the feed, and the payload parameter has
3737
# the new value.

examples/mqtt_subscribe.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ def disconnected(client):
3333
print('Disconnected from Adafruit IO!')
3434
sys.exit(1)
3535

36-
def message(client, feed_id, payload):
36+
def message(client, feed_id, payload, retain):
3737
# Message function will be called when a subscribed feed has a new value.
3838
# The feed_id parameter identifies the feed, and the payload parameter has
3939
# the new value.

examples/mqtt_viewall.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ def on_connect(client, userdata, flags, rc):
5050
def on_disconnect(client, userdata, rc):
5151
print('Disconnected!')
5252

53-
def on_message(client, userdata, msg):
53+
def on_message(client, userdata, msg, retain):
5454
print('Received on {0}: {1}'.format(msg.topic, msg.payload.decode('utf-8')))
5555

5656

0 commit comments

Comments
 (0)