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();