提交 818fb72c authored 作者: yangli's avatar yangli

.

上级 de51ea5c
...@@ -356,7 +356,8 @@ public class MqttServiceImpl implements MqttService, MqttHandler, MqttClientCall ...@@ -356,7 +356,8 @@ public class MqttServiceImpl implements MqttService, MqttHandler, MqttClientCall
private void onRpcCommand(String message) { private void onRpcCommand(String message) {
JsonNode payload = fromString(message); JsonNode payload = fromString(message);
MqttRpcDataMessage mqttRpcDataMessage = MqttRpcDataMessage.builder() MqttRpcDataMessage mqttRpcDataMessage = MqttRpcDataMessage.builder()
.method(payload.get("method").asText()).params(payload.get("params").asText()).build(); .method(payload.get("method").asText())
.params(Optional.ofNullable(payload.get("params")).map(JsonNode::asText).orElse(null)).build();
// 存储rpc下发的数据 // 存储rpc下发的数据
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论