package com.dy.pipIrrApp.workOrder.mqtt;

import lombok.extern.slf4j.Slf4j;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;

/**
 * @author ZhuBaoMin
 * @date 2024-11-16 11:28
 * @LastEditTime 2024-11-16 11:28
 * @Description 消息发送方法
 */

@Slf4j
public class MqttMsgSender {
    public void sendMessage(MqttClient client, String topic, String content, int qos){
        MqttMessage message = new MqttMessage(content.getBytes());
        message.setQos(qos);
        try{
            client.publish(topic,message);
        } catch (MqttException e){
            log.error("MqttClient publish text info Error:{}!", e.getMessage());
            e.printStackTrace();
        }
    }
}