package com.zy.integration.iot.client; public interface IotMqttClient { void ensureConnected() throws Exception; void publish(String topic, String payload) throws Exception; boolean isConnected(); }