From ca34b93e5ddb93828094296863785468d6507910 Mon Sep 17 00:00:00 2001
From: jmacwhyte <macwhyte@gmail.com>
Date: Wed, 20 Jul 2022 21:00:43 +0100
Subject: [PATCH] add last-will-and-testament to MQTT

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

diff --git a/net/mqtt/mqtt.go b/net/mqtt/mqtt.go
index 427e39d..1c0c073 100644
--- a/net/mqtt/mqtt.go
+++ b/net/mqtt/mqtt.go
@@ -100,6 +100,12 @@ func (c *mqttclient) Connect() Token {
 	connectPkt.ProtocolName = "MQTT"
 	connectPkt.Keepalive = 60
 
+	connectPkt.WillFlag = c.opts.WillEnabled
+	connectPkt.WillTopic = c.opts.WillTopic
+	connectPkt.WillMessage = c.opts.WillPayload
+	connectPkt.WillQos = c.opts.WillQos
+	connectPkt.WillRetain = c.opts.WillRetained
+
 	err = connectPkt.Write(c.conn)
 	if err != nil {
 		return &mqtttoken{err: err}