代码整理

yangys

2024-11-21 fe82f1f9a9be911d1420fe3b018ea85dd5fff1a3

 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
@@ -61,6 +65,9 @@
    */
   public static final String FEEDBACK_TOPIC = "mdc/feedback";
   
   /**
    * 工位创建消息，mdc中新建工位时发送，本应用接收并处理
    */
   public static final String WOCKSTATION_CREATE_TOPIC = "mdc/workstation-create";
   
   /**
@@ -73,6 +80,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);