Agent/tr-agent-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

agent注册交换机增加索引过滤

Browse Source
This commit is contained in:
qiminbao
2025-09-26 17:19:16 +08:00
parent 25daeb737d
commit 55780c8bfd
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java
+5
View File
@@ -99,6 +99,7 @@ public class AgentConsumerDownListener implements RocketMQListener<String> {
String pwrOID = ""; String pwrOID = "";
String fanOID = ""; String fanOID = "";
String otherOID = ""; String otherOID = "";
String filters = "";
JSONObject json = JSONObject.parseObject(switchBoard); JSONObject json = JSONObject.parseObject(switchBoard);
if(json.containsKey("community")){ if(json.containsKey("community")){
community = json.getString("community"); community = json.getString("community");
@@ -127,6 +128,9 @@ public class AgentConsumerDownListener implements RocketMQListener<String> {
if(json.containsKey("otherOID")){ if(json.containsKey("otherOID")){
otherOID = json.getString("otherOID"); otherOID = json.getString("otherOID");
} }
if(json.containsKey("filters")){
filters = json.getString("filters");
}
JSONObject switchBoardJson = new JSONObject(); JSONObject switchBoardJson = new JSONObject();
switchBoardJson.put("community",community); switchBoardJson.put("community",community);
switchBoardJson.put("ip",switchIp); switchBoardJson.put("ip",switchIp);
@@ -137,6 +141,7 @@ public class AgentConsumerDownListener implements RocketMQListener<String> {
switchBoardJson.put("pwrOID",pwrOID); switchBoardJson.put("pwrOID",pwrOID);
switchBoardJson.put("fanOID",fanOID); switchBoardJson.put("fanOID",fanOID);
switchBoardJson.put("otherOID",otherOID); switchBoardJson.put("otherOID",otherOID);
switchBoardJson.put("filters",filters);
object.put("switchBoard",switchBoardJson.toString()); object.put("switchBoard",switchBoardJson.toString());
AssertLog.info("交换机配置信息={}",switchBoardJson.toString()); AssertLog.info("交换机配置信息={}",switchBoardJson.toString());
} }