package com.zy.integration.iot.client;

public interface IotMqttClient {

    void ensureConnected() throws Exception;

    void publish(String topic, String payload) throws Exception;

    boolean isConnected();

    /** 重新读库并断开/重建连接，用于后台改配置后生效。 */
    void reconnectFromDbConfig();
}