diff --git a/src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java b/src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java index 3c5f63e..527b18d 100644 --- a/src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java +++ b/src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java @@ -99,6 +99,7 @@ public class AgentConsumerDownListener implements RocketMQListener { String pwrOID = ""; String fanOID = ""; String otherOID = ""; + String filters = ""; JSONObject json = JSONObject.parseObject(switchBoard); if(json.containsKey("community")){ community = json.getString("community"); @@ -127,6 +128,9 @@ public class AgentConsumerDownListener implements RocketMQListener { if(json.containsKey("otherOID")){ otherOID = json.getString("otherOID"); } + if(json.containsKey("filters")){ + filters = json.getString("filters"); + } JSONObject switchBoardJson = new JSONObject(); switchBoardJson.put("community",community); switchBoardJson.put("ip",switchIp); @@ -137,6 +141,7 @@ public class AgentConsumerDownListener implements RocketMQListener { switchBoardJson.put("pwrOID",pwrOID); switchBoardJson.put("fanOID",fanOID); switchBoardJson.put("otherOID",otherOID); + switchBoardJson.put("filters",filters); object.put("switchBoard",switchBoardJson.toString()); AssertLog.info("交换机配置信息={}",switchBoardJson.toString()); }