We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2cfc08b commit ca34b93Copy full SHA for ca34b93
net/mqtt/mqtt.go
@@ -100,6 +100,12 @@ func (c *mqttclient) Connect() Token {
100
connectPkt.ProtocolName = "MQTT"
101
connectPkt.Keepalive = 60
102
103
+ connectPkt.WillFlag = c.opts.WillEnabled
104
+ connectPkt.WillTopic = c.opts.WillTopic
105
+ connectPkt.WillMessage = c.opts.WillPayload
106
+ connectPkt.WillQos = c.opts.WillQos
107
+ connectPkt.WillRetain = c.opts.WillRetained
108
+
109
err = connectPkt.Write(c.conn)
110
if err != nil {
111
return &mqtttoken{err: err}
0 commit comments