jiangping
2023-10-11 17dbe1fed8e1e51ae1cc446955c1adbff72d007d
server/services/src/main/java/com/doumee/core/mqtt/config/MqttClientInit.java
@@ -11,8 +11,6 @@
public class MqttClientInit {
        static MqttClient client;
        private String userName = "doumee";
        private String passWord = "doumee@168";
        public static synchronized MqttClient getInstance(MqttConfig config,MqttPushCallback callBack){
            if(client !=null){
@@ -41,7 +39,6 @@
                //遗嘱
                options.setWill(topic, "close".getBytes(), 1, true);
                client.connect(options);
            } catch (Exception e) {
                e.printStackTrace();
            }