using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Collections.Concurrent;
using System.Threading;
using System.Runtime.InteropServices;
namespace Paho.MqttDotnet
{
///
/// 断开丢失委托
///
/// 触发者
public delegate void ConnectionLostdHandler(object sender);
///
/// 收到消息委托
///
/// 触发者
/// 主题
/// 消息
public delegate void MessageArrivedHandler(object sender, string topic, MqttMessage message);
///
/// 表示mqtt客户端
///
unsafe public class MqttClient : SafeHandle
{
///
/// 用于保存最近的连接配置项
///
private ConnectOption connectOpt;
///
/// 用于生成任务的id
///
private int taskIdValue = 0;
///
/// 用于保存对象的引用
///
private readonly HashSet