From 2cfc08b560bdb3c6c8e5e0b157061a4551850d15 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Kamil=20Wcis=C5=82o?= <mek.xgt@gmail.com>
Date: Wed, 20 Jul 2022 10:40:53 +0200
Subject: [PATCH] net/mqtt: add support for retained messsages

---
 net/mqtt/mqtt.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/net/mqtt/mqtt.go b/net/mqtt/mqtt.go
index bfbbb5f..427e39d 100644
--- a/net/mqtt/mqtt.go
+++ b/net/mqtt/mqtt.go
@@ -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))