mirror of
https://github.com/fhmq/hmq.git
synced 2026-05-06 07:35:32 +00:00
fixed
This commit is contained in:
+1
-1
@@ -132,7 +132,7 @@ func wrapPublishPacket(packet *packets.PublishPacket) *packets.PublishPacket {
|
|||||||
|
|
||||||
func unWrapPublishPacket(packet *packets.PublishPacket) *packets.PublishPacket {
|
func unWrapPublishPacket(packet *packets.PublishPacket) *packets.PublishPacket {
|
||||||
p := packet.Copy()
|
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())
|
p.Payload = []byte(gjson.GetBytes(p.Payload, "payload").String())
|
||||||
}
|
}
|
||||||
return p
|
return p
|
||||||
|
|||||||
Reference in New Issue
Block a user