jiaosong
2023-10-24 55acb5b341f9374ddaa33c2ca1d30e3730805e89
server/services/src/main/java/com/doumee/core/mqtt/service/MqttToolService.java
@@ -26,7 +26,7 @@
            for (int i = 0; i < Qos.length; i++) {
                Qos[i] = 1;
            }
            MqttClientInit.getInstance(config,callBack).subscribe(topics, Qos);
            MqttClientInit.getSubInstance(config,callBack).subscribe(topics, Qos);
        } catch (Exception e) {
            e.printStackTrace();
        }
@@ -42,7 +42,7 @@
        mess.setRetained(true);
        mess.setPayload(message.getBytes());
        try {
            MqttClientInit.getInstance(config,callBack).publish(topic, mess);
            MqttClientInit.getInstance(config).publish(topic, mess);
            return  0;
        } catch (Exception e) {
            //LOGGER.error(e.getLocalizedMessage());