增加离线检查定时任务的逻辑

yangys

2024-11-13 04d53749b21921c9bceebe120d170c2ee6e533af

 collect/src/main/java/com/qianwen/mdc/collect/config/MqttConfig.java

@@ -41,6 +41,10 @@

    @Value("${mqtt.password:}")
    private String mqttPassword;
    
    @Value("${mqtt.timeout:1000}")
    private int timeout;
    
   @Autowired
   private IOTMqttReceiveService recService;
   @Autowired
@@ -73,6 +77,7 @@
        DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory();
        MqttConnectOptions options = new MqttConnectOptions();
        options.setServerURIs(new String[] { mqttHost});//"tcp://82.156.1.83:1884" 
        options.setConnectionTimeout(timeout);
        
        if(ObjectUtil.isNotEmpty(mqttUserName)) {
           options.setUserName(mqttUserName);