修復bug

jiangping

2023-10-09 c2b44a985d16842ba73c1b6e213a653013a7157a

 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();
            }