// 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(false);
client.SetEntitlementToken("{{ token }}");
client.SetServers(new string[] { "{{ server }}" });
List<string> subjects = new List<string>();
subjects.Add("{{ subject }}");
client.Subscribe(subjects);
client.Connect();
// publish a message every 3 seconds
int count = 1;
while (count < 1000000)
{
client.Publish(new MigratoryDataMessage("{{ subject }}", 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);
}
}
}
}