diff --git a/broker/comm.go b/broker/comm.go index db83deb..30c0e34 100644 --- a/broker/comm.go +++ b/broker/comm.go @@ -132,7 +132,7 @@ func wrapPublishPacket(packet *packets.PublishPacket) *packets.PublishPacket { func unWrapPublishPacket(packet *packets.PublishPacket) *packets.PublishPacket { p := packet.Copy() - if gjson.GetBytes(p.Payload, "paload").Exists() { + if gjson.GetBytes(p.Payload, "payload").Exists() { p.Payload = []byte(gjson.GetBytes(p.Payload, "payload").String()) } return p