ems-framework/src/main/java/com/xzzn/framework/aspectj/FaultProtPlanAspect.java

@@ -118,10 +118,10 @@ public class FaultProtPlanAspect {
             return;
         }
         // 校验是否配置监听topic-监听则不发布
-        /*String topic = emsMqttTopicConfigMapper.checkTopicIsExist(MQTT_TOPIC);
+        String topic = emsMqttTopicConfigMapper.checkTopicIsExist(MQTT_TOPIC);
         if (!StringUtils.isEmpty(topic)) {
             return;
-        }*/
+        }
 
         // 解析方法名，获取操作类型（INSERT/UPDATE/DELETE）和表名
         String methodName = joinPoint.getSignature().getName();