net/mqtt: add support for retained messsages

2026-08-06 07:53:41 +00:00 · 2022-07-20 10:40:53 +02:00
parent 1850c5effb
commit 2cfc08b560
1 changed files with 1 additions and 0 deletions
@@ -146,6 +146,7 @@ func (c *mqttclient) Publish(topic string, qos byte, retained bool, payload inte
 	pub := packets.NewControlPacket(packets.Publish).(*packets.PublishPacket)
 	pub.Qos = qos
 	pub.TopicName = topic
+	pub.Retain = retained
 	switch payload.(type) {
 	case string:
 		pub.Payload = []byte(payload.(string))