dagent - milestone

使用 Message.rpcResultMsg 返回 RPC 调用结果

dagent/src/main/java/cn/reghao/autodop/dagent/mqttsub/MqttRpcListener.java

@@ -54,7 +54,7 @@ public class MqttRpcListener implements MqttCallback {
                     rpcMsg.error(err);
             }
 
-            Message message1 = Message.rpcMsg(rpcMsg, MsgType.rpcResult);
+            Message message1 = Message.rpcResultMsg(msgId, rpcMsg);
             rpcReply(message1);
         } catch (Exception e) {
             log.error("MQTT message exception -> {}", e.getMessage());