add last-will-and-testament to MQTT

This commit is contained in:
jmacwhyte
2022-07-20 21:00:43 +01:00
committed by Ron Evans
parent 2cfc08b560
commit ca34b93e5d
+6
View File
@@ -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}