Mirrors_Framework/mosquitto
1
0
Fork 0
mirror of https://github.com/eclipse-mosquitto/mosquitto.git synced 2026-09-27 22:29:31 +08:00
Code Issues Packages Projects Releases Wiki Activity

msg_sequence: Add optional external publish retain support

Browse Source
This commit is contained in:
Roger A. Light
2026-06-13 08:15:37 +01:00
parent 63619458c7
commit 39beaa8134
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
test/broker/msg_sequence_test.py
+8 -3
View File
@@ -75,13 +75,18 @@ class MsgSequence(object):
mosq_test.expect_packet(sock, "connack", mqtt_packets.gen_connack(rc=0)) mosq_test.expect_packet(sock, "connack", mqtt_packets.gen_connack(rc=0))
m = msg.message m = msg.message
try:
retain = m['retain']
except KeyError:
retain = False
if m['qos'] == 0: if m['qos'] == 0:
sock.send(mqtt_packets.gen_publish(topic=m['topic'], qos=0, payload=m['payload'])) sock.send(mqtt_packets.gen_publish(topic=m['topic'], qos=0, payload=m['payload'], retain=retain))
elif m['qos'] == 1: elif m['qos'] == 1:
sock.send(mqtt_packets.gen_publish(mid=1, qos=1, topic=m['topic'], payload=m['payload'])) sock.send(mqtt_packets.gen_publish(mid=1, qos=1, topic=m['topic'], payload=m['payload'], retain=retain))
mosq_test.expect_packet(sock, "helper puback", mqtt_packets.gen_puback(mid=1)) mosq_test.expect_packet(sock, "helper puback", mqtt_packets.gen_puback(mid=1))
elif m['qos'] == 2: elif m['qos'] == 2:
sock.send(mqtt_packets.gen_publish(mid=1, qos=2, topic=m['topic'], payload=m['payload'])) sock.send(mqtt_packets.gen_publish(mid=1, qos=2, topic=m['topic'], payload=m['payload'], retain=retain))
mosq_test.expect_packet(sock, "helper pubrec", mqtt_packets.gen_pubrec(mid=1)) mosq_test.expect_packet(sock, "helper pubrec", mqtt_packets.gen_pubrec(mid=1))
sock.send(mqtt_packets.gen_pubrel(mid=1)) sock.send(mqtt_packets.gen_pubrel(mid=1))
mosq_test.expect_packet(sock, "helper pubcomp", mqtt_packets.gen_pubcomp(mid=1)) mosq_test.expect_packet(sock, "helper pubcomp", mqtt_packets.gen_pubcomp(mid=1))