using System;

using System.Text;

using System.Threading;

using Newtonsoft.Json.Linq;

using uPLibrary.Networking.M2Mqtt;

using uPLibrary.Networking.M2Mqtt.Messages;

​

public class Program

{

    public static void Main()

    {

        // create connection

        MqttClient client = new MqttClient("207.154.213.43");

        client.Connect(Guid.NewGuid().ToString(), "W3dwXLii28lFtUBRcURB", "");

        for (int i = 0; i < 100; i++)

        {

            // create telemetry object

            dynamic telemetry = new JObject();

            //telemetry.count = i;

            telemetry.ProductionCount = RandomNumber(1, 6);

            telemetry.Stop = RandomNumber(0, 2);

            telemetry.DefectCount = RandomNumber(0, 1);

            // publish a message

            client.Publish("v1/devices/me/telemetry", Encoding.UTF8.GetBytes(Convert.ToString(telemetry)), MqttMsgBase.QOS_LEVEL_AT_MOST_ONCE, false);

            Console.WriteLine(Convert.ToString(telemetry));

            // wait 1 sec.

            Thread.Sleep(1000);

        }

    }

​

    static Random random = new Random();

    static double RandomNumber(double min, double max)

    {

        return random.NextDouble() * (max - min) + min;

    }

}