增加上报应答

src/main/java/com/tongran/agent/server/core/enums/MsgEnum.java

@@ -40,6 +40,8 @@ public enum MsgEnum {
 
     交换机上报("SWITCHBOARD"),
 
+    采集上报应答("COLLECT_RSP"),
+
     开启或更新系统采集("SYSTEM_COLLECT_START"),
 
     开启或更新系统采集应答("SYSTEM_COLLECT_START_RSP"),

src/main/java/com/tongran/agent/server/netty/enpoint/AgentEndpoint.java

@@ -97,7 +97,10 @@ public class AgentEndpoint {
             jsonObject.put("data", data);
             MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
             agentProducer.asyncSend(mqMsg);
-            return null;
+            JSONObject json = new JSONObject();
+            json.put("resCode",1);
+            return UpMsgResponse.builder().clientId(clientId).dataType(MsgEnum.采集上报应答.getValue())
+                    .content(json.toString()).build();
         }
     }
 
@@ -111,7 +114,10 @@ public class AgentEndpoint {
             jsonObject.put("data", data);
             MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
             agentProducer.asyncSend(mqMsg);
-            return null;
+            JSONObject json = new JSONObject();
+            json.put("resCode",1);
+            return UpMsgResponse.builder().clientId(clientId).dataType(MsgEnum.采集上报应答.getValue())
+                    .content(json.toString()).build();
         }
     }
 
@@ -125,7 +131,10 @@ public class AgentEndpoint {
             jsonObject.put("data", data);
             MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
             agentProducer.asyncSend(mqMsg);
-            return null;
+            JSONObject json = new JSONObject();
+            json.put("resCode",1);
+            return UpMsgResponse.builder().clientId(clientId).dataType(MsgEnum.采集上报应答.getValue())
+                    .content(json.toString()).build();
         }
     }
 
@@ -139,7 +148,10 @@ public class AgentEndpoint {
             jsonObject.put("data", data);
             MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
             agentProducer.asyncSend(mqMsg);
-            return null;
+            JSONObject json = new JSONObject();
+            json.put("resCode",1);
+            return UpMsgResponse.builder().clientId(clientId).dataType(MsgEnum.采集上报应答.getValue())
+                    .content(json.toString()).build();
         }
     }
 
@@ -153,7 +165,10 @@ public class AgentEndpoint {
             jsonObject.put("data", data);
             MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
             agentProducer.asyncSend(mqMsg);
-            return null;
+            JSONObject json = new JSONObject();
+            json.put("resCode",1);
+            return UpMsgResponse.builder().clientId(clientId).dataType(MsgEnum.采集上报应答.getValue())
+                    .content(json.toString()).build();
         }
     }
 
@@ -167,7 +182,10 @@ public class AgentEndpoint {
             jsonObject.put("data", data);
             MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
             agentProducer.asyncSend(mqMsg);
-            return null;
+            JSONObject json = new JSONObject();
+            json.put("resCode",1);
+            return UpMsgResponse.builder().clientId(clientId).dataType(MsgEnum.采集上报应答.getValue())
+                    .content(json.toString()).build();
         }
     }
 
@@ -181,7 +199,10 @@ public class AgentEndpoint {
             jsonObject.put("data", data);
             MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
             agentProducer.asyncSend(mqMsg);
-            return null;
+            JSONObject json = new JSONObject();
+            json.put("resCode",1);
+            return UpMsgResponse.builder().clientId(clientId).dataType(MsgEnum.采集上报应答.getValue())
+                    .content(json.toString()).build();
         }
     }
 
@@ -195,7 +216,10 @@ public class AgentEndpoint {
             jsonObject.put("data", data);
             MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
             agentProducer.asyncSend(mqMsg);
-            return null;
+            JSONObject json = new JSONObject();
+            json.put("resCode",1);
+            return UpMsgResponse.builder().clientId(clientId).dataType(MsgEnum.采集上报应答.getValue())
+                    .content(json.toString()).build();
         }
     }