yuanbiao
/
jetlinks-official-protocol
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修复encode错误

This commit is contained in:
zhou-hao 2021-01-26 16:40:57 +08:00
parent 53b349efee
commit 9ff537a4ea
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/org/jetlinks/protocol/official/JetLinksMqttDeviceMessageCodec.java
View File

@ -85,7 +85,7 @@ public class JetLinksMqttDeviceMessageCodec implements DeviceMessageCodec {
.clientId(deviceMessage.getDeviceId()) .clientId(deviceMessage.getDeviceId())
.topic("/".concat(productId).concat(convertResult.getTopic())) .topic("/".concat(productId).concat(convertResult.getTopic()))
.payloadType(MessagePayloadType.JSON) .payloadType(MessagePayloadType.JSON)
.payload(Unpooled.wrappedBuffer(JSON.toJSONBytes(convertResult.getPayload()))) .payload(Unpooled.wrappedBuffer(convertResult.getPayload()))
.build()); .build());
} else { } else {
return Mono.empty(); return Mono.empty();