package com.doumee.mqtt.service;

import com.doumee.mqtt.config.MqttConfig;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttMessage;

/**
 * 与硬件对接服务
 * @author 江蹄蹄
 * @date 2023/10/09 18:06
 */
public interface MqttBizService {

    /**
     * 按配置订阅
     * @param config
     * @param topics
     */
    MqttClient subscribe(MqttClient client,MqttConfig config, String[] topics);
    MqttClient unsubscribe(MqttClient client,MqttConfig config, String[] topics);
    /**
     * 按配置发布消息
     * @param config
     * @param topic
     */
    MqttClient publish(MqttClient client,MqttConfig config,String topic,String param);

}