优化报警

puzhibing

2025-06-03 f58d0913c810c68c550e5b12da64dbdeb0d0c1f0

 ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/util/mqtt/MqttInit.java

@@ -14,6 +14,7 @@
@Slf4j
@Component
public class MqttInit {

   @Autowired
   private MqttPahoMessageDrivenChannelAdapter messageDrivenChannelAdapter;
   
@@ -21,6 +22,8 @@
   public void init() {
      subscribeAllTopics();
   }


   public void subscribeAllTopics() {
      messageDrivenChannelAdapter.addTopic("artemis/event_msa_alarm/5201154049/admin");
   }