WEP_V2.1.3/SourceCode/We.Zero/IwbYue.Zero/MqttClient/IIwbMsgClient.cs

using System.Threading.Tasks;
using Abp.Dependency;
using MQTTnet.Client.Receiving;

namespace IwbZero.MqttClient
{
    public interface IIwbMsgClient : ISingletonDependency
    {
        bool NotValidate { get; }

        void SetOptions(string serverIp, int serverPort, string clientId, string serverUserId, string serverPassword,
            IMqttApplicationMessageReceivedHandler receivedHandler);

        Task SubscribeTopic(string topic);

        Task SendMsg(string topic, string msg);

        Task SendMsg(string topic, string msg, string clientId);


    }
}