MQ消息发送类型修复

2025-08-26 16:36:04 +08:00
parent 95377c9565
commit 6637647a49
1 changed files with 1 additions and 1 deletions
@@ -137,7 +137,7 @@ public class AgentEndpoint {
        @Override
        public UpMsgResponse upHandle(String data, String clientId) {
            JSONObject jsonObject = JSONObject.parseObject(data);
-            jsonObject.put("dataType",MsgEnum.CPU包.getValue());
+            jsonObject.put("dataType",MsgEnum.磁盘包.getValue());
            MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
            agentProducer.asyncSend(mqMsg);
            JSONObject json = new JSONObject();