111

k94314517

2023-10-13 07088f4225d6c8d21e94cc4981d4c28960f114d8

 server/services/src/main/java/com/doumee/core/mqtt/service/MqttToolService.java

@@ -36,16 +36,18 @@
     * @param message
     * @param topic
     */
    public  void pubMessage(String message,String topic){
    public  int pubMessage(String message,String topic){
        MqttMessage mess = new MqttMessage();
        mess.setQos(1);
        mess.setRetained(true);
        mess.setPayload(message.getBytes());
        try {
            MqttClientInit.getInstance(config,callBack).publish(topic, mess);
            return  0;
        } catch (Exception e) {
            //LOGGER.error(e.getLocalizedMessage());
        }
        return 1;
    }
    public static void main(String[] args) {
        MqttToolService client1 = new MqttToolService();