From dd6ff28d595c4cfb11d80b7b52e68b6eed0f8422 Mon Sep 17 00:00:00 2001 From: "joy.zhou" Date: Thu, 18 Jul 2019 14:00:03 +0800 Subject: [PATCH] fixed --- broker/comm.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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