发布消息增加分发方法

NewLifeX · Dec 14, 2023 · c4d5807 · c4d5807
1 parent b68acd2
commit c4d5807
Showing 1 changed file with 29 additions and 0 deletions.
diff --git a/NewLife.MQTT/Handlers/IMqttHandler.cs b/NewLife.MQTT/Handlers/IMqttHandler.cs
@@ -22,6 +22,14 @@ public interface IMqttHandler
     /// <returns></returns>
     Task<MqttIdMessage> PublishAsync(String topic, Object data, QualityOfService qos = QualityOfService.AtMostOnce);
 
+    /// <summary>发布消息</summary>
+    /// <param name="topic">主题</param>
+    /// <param name="data">消息数据</param>
+    /// <param name="qos">服务质量</param>
+    /// <param name="AllowExchange">允许消息交换</param>
+    /// <returns></returns>
+    Task<MqttIdMessage> PublishAsync(String topic, Object data, Boolean AllowExchange, QualityOfService qos = QualityOfService.AtMostOnce);
+
     /// <summary>发布消息</summary>
     /// <param name="message">消息</param>
     /// <returns></returns>
@@ -176,6 +184,27 @@ public async Task<MqttIdMessage> PublishAsync(String topic, Object data, Quality
         return await PublishAsync(message);
     }
 
+    /// <summary>发布消息</summary>
+    /// <param name="topic">主题</param>
+    /// <param name="data">消息数据</param>
+    /// <param name="qos">服务质量</param>
+    /// <param name="AllowExchange">允许消息交换</param>
+    /// <returns></returns>
+    public async Task<MqttIdMessage> PublishAsync(String topic, Object data, Boolean AllowExchange, QualityOfService qos = QualityOfService.AtMostOnce)
+    {
+        var pk = data as Packet;
+        if (pk == null && data != null) pk = Serialize(data);
+
+        var message = new PublishMessage
+        {
+            Topic = topic,
+            Payload = pk,
+            QoS = qos,
+        };
+
+        return await PublishAsync(message);
+    }
+
     /// <summary>发布消息</summary>
     /// <param name="message">消息</param>
     /// <returns></returns>