We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 65f43bd commit 1bd25d9Copy full SHA for 1bd25d9
net.go
@@ -267,6 +267,7 @@ func alllogic(c *client) {
267
pa := packets.NewControlPacket(packets.Puback).(*packets.PubackPacket)
268
pa.MessageID = m.MessageID
269
DEBUG.Println(NET, "putting puback msg on obound")
270
+ persistOutbound(c.persist, pa)
271
select {
272
case c.oboundP <- &PacketAndToken{p: pa, t: nil}:
273
case <-c.stop:
@@ -297,6 +298,7 @@ func alllogic(c *client) {
297
298
DEBUG.Println(NET, "received pubrel, id:", m.MessageID)
299
pc := packets.NewControlPacket(packets.Pubcomp).(*packets.PubcompPacket)
300
pc.MessageID = m.MessageID
301
+ persistOutbound(c.persist, pc)
302
303
case c.oboundP <- &PacketAndToken{p: pc, t: nil}:
304
0 commit comments