From 6637647a49ed6496c0d45227e6f70d061957d43f Mon Sep 17 00:00:00 2001 From: qiminbao Date: Tue, 26 Aug 2025 16:36:04 +0800 Subject: [PATCH] =?UTF-8?q?MQ=E6=B6=88=E6=81=AF=E5=8F=91=E9=80=81=E7=B1=BB?= =?UTF-8?q?=E5=9E=8B=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/tongran/agenttcp/server/enpoint/AgentEndpoint.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/tongran/agenttcp/server/enpoint/AgentEndpoint.java b/src/main/java/com/tongran/agenttcp/server/enpoint/AgentEndpoint.java index 491b20c..f14e2b6 100644 --- a/src/main/java/com/tongran/agenttcp/server/enpoint/AgentEndpoint.java +++ b/src/main/java/com/tongran/agenttcp/server/enpoint/AgentEndpoint.java @@ -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();