MigratoryData.Client.DotNet 6.0.10

MigratoryData Client SDK for .Net

RELEASE 6.0.10

• fix: Uncaught NullPointerException when calling client.Disconnect().

RELEASE 6.0.9

• add support for traefik proxy.

RELEASE 6.0.8

• fix: catch exception when dns resolve throws exception No such host is known.

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/client-api/dotnet/

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.10

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

In this example the MigratoryData Client API is set to connect to the MigratoryData server located at address localhost:8800 and subscribe to the subject /server/status.

If you don't have a MigratoryData server installed on your machine but there is docker installed you can run the following commands to start MigratoryData server, otherwise you can download and install the latest version for your os from here.

docker pull migratorydata/server:latest
docker run -d --name my_migratorydata -p 8800:8800 migratorydata/server:latest

// For API documentation go to (Developer’s Guide)[https://migratorydata.com/docs/client-api/dotnet/]
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);
            }
        }
    }
}