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