zengzy / hhrcs_service · Files

using MQTTnet.Client;
using Rcs.Domain.Entities;

namespace Rcs.Infrastructure.Mqtt
{
    /// <summary>
    /// MQTT消息处理器
    /// </summary>
    public interface IMqttMessageHandler
    {
        /// <summary>
        /// MQTT消息处理
        /// </summary>
        /// <param name="e"></param>
        /// <returns></returns>
        Task HandleMessageAsync(MqttApplicationMessageReceivedEventArgs e);
        /// <summary>
        /// 重置mqtt消息头id
        /// </summary>
        /// <param name="robot"></param>
        /// <returns></returns>
        Task ResetHeaderIdsAsync(Robot robot);
    }
}