package com.tievd.jyz.mqtt;

import com.tievd.jyz.config.mqtt.MqttGateway;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * mqtt消息发送者
 * @author timi
 */
@Component
public class MqttMsgSender {
    @Autowired
    private MqttGateway mqttGateway;

    /**
     * 发送消息
     * @param data  发送内容
     * @param topic 主题
     */
    public void sendToMqtt(String data,  String topic){
        mqttGateway.sendToMqtt(data,topic);
    }

}