// See https://aka.ms/new-console-template for more information

using System;

using System.Text;

using System.Threading;

using MQTTnet;

using MQTTnet.Client;

using MQTTnet.Client.Options;

​

Console.WriteLine("Subscriber");

var mqttFactory = new MqttFactory();

IMqttClient mqttClient = mqttFactory.CreateMqttClient();

var mqttClientOptions = new MqttClientOptionsBuilder()

                        .WithClientId(Guid.NewGuid().ToString())

                        .WithTcpServer("test.mosquitto.org", 1883)

                        //.WithWebSocketServer("broker.hivemq.com:8000/mqtt")

                        .WithCleanSession()

                        .Build();

​

mqttClient.UseConnectedHandler(async e =>

{

    Console.WriteLine("Connected to the Broker Succesfully");

    var topicFilter = new TopicFilterBuilder()

                        .WithTopic("astar/vfarmproject")

                        .Build();

    await mqttClient.SubscribeAsync(topicFilter);

});

​

mqttClient.UseDisconnectedHandler(e =>

{

    Console.WriteLine("Disconnected to the Broker Succesfully");

});

​

mqttClient.UseApplicationMessageReceivedHandler(e =>

{

    Console.WriteLine($"Received Message - {Encoding.UTF8.GetString(e.ApplicationMessage.Payload)}");

});

​

await mqttClient.ConnectAsync(mqttClientOptions, CancellationToken.None);

​

Console.ReadLine();

​

await mqttClient.DisconnectAsync();

​

​