MigratoryData.Client.DotNet 6.0.3

MigratoryData Client SDK for .Net

DOCUMENTATION

Please refer to the Developer's Guide and the Reference Manual of the MigratoryData Client SDK for .Net located at:

https://migratorydata.com/docs/migratorydata-client-sdks/dotnet/getting_started/

SAMPLE

Steps for building realtime client applications using C# .NET

Prerequisites

.Net SDK

Create Project

Create a getting started project with:

dotnet new console -n getting-started-csharp-client-api

Add API library

Change to the folder of your project and add the API library with:

dotnet add package MigratoryData.Client.DotNet --version 6.0.3

Configure

Copy the below code snippet to the file Program.cs of your project.

Build & Run

Use the following command to build and run your project:

dotnet run

Play

Open the Console page of MigratoryData Cloud, connect and subscribe to the default subject to see how messages published by this client application are received in realtime. Also, publish from the Console messages on the default subject and see in the output of this client application how messages are received in realtime.

// For API documentation go to (Developer’s Guide)[https://migratorydata.com/docs/migratorydata-client-sdks/dotnet/getting_started/]
using System;
using System.Collections.Generic;
using com.migratorydata.client;
using System.Threading;
namespace example
{
    class Program
    {
        static void Main(string[] args)
        {
            MigratoryDataClient client = new MigratoryDataClient();
            client.SetLogListener(new LogList(), MigratoryDataLogLevel.DEBUG);
            client.SetListener(new Listener());

            //client.SetEncryption(true);
            client.SetEntitlementToken("some-token");
            client.SetServers(new string[] { "127.0.0.1:8800" });

            List<string> subjects = new List<string>();
            subjects.Add("/server/status");
            client.Subscribe(subjects);

            client.Connect();

            // publish a message every 3 seconds
            int count = 1;
            while (count < 1000000)
            {
                client.Publish(new MigratoryDataMessage("/server/status", System.Text.Encoding.ASCII.GetBytes("data - " + count), "id" + count));
                count++;
                Thread.Sleep(3000);
            }
        }
        class Listener : MigratoryDataListener
        {
            public void OnMessage(MigratoryDataMessage message)
            {
                System.Console.WriteLine(message.ToString());
            }
            public void OnStatus(string status, string info)
            {
                System.Console.WriteLine(status + " " + info);
            }
        }
        class LogList : MigratoryDataLogListener
        {
            public void OnLog(string log, MigratoryDataLogLevel level)
            {
                string msg = string.Format("[{0:G}] [{1}] {2}", DateTime.Now, level, log);
                Console.WriteLine(msg);
            }
        }
    }
}