using IStation.DataDockingMqtt4SQI_DEMO;
|
using MQTTnet;
|
using MQTTnet.Client.Connecting;
|
using MQTTnet.Client.Options;
|
using MQTTnet.Client.Receiving;
|
using MQTTnet.Extensions.ManagedClient;
|
using MQTTnet.Server;
|
using System;
|
using System.Collections.Generic;
|
using System.Diagnostics.Tracing;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace IStation.DataDockingMqtt
|
{
|
internal class Program
|
{
|
static void Main(string[] args)
|
{
|
Console.WriteLine("启动 上海质检所 MQTT!");
|
/*Mqtt1.Connect();
|
Mqtt2.Connect();*/
|
Mqtt.Connect();
|
Console.ReadLine();
|
}
|
}
|
|
class ClientConnectingFaildHandler : IConnectingFailedHandler
|
{
|
Action<ManagedProcessFailedEventArgs> action;
|
|
public ClientConnectingFaildHandler(Action<ManagedProcessFailedEventArgs> a)
|
{
|
action = a;
|
}
|
public Task HandleConnectingFailedAsync(ManagedProcessFailedEventArgs eventArgs)
|
{
|
action(eventArgs);
|
return Task.CompletedTask;
|
}
|
}
|
}
|