//
// Clone client, Model One in C#
//
// Author: Yan Cui
// Email: moc.liamg|knomgninrubeht#moc.liamg|knomgninrubeht
using System;
using System.Collections.Generic;
using System.Text;
using ZMQ;
namespace ZMQGuide
{
internal class Program
{
public static void Main(string[] args)
{
using (var context = new Context(1))
{
using (var subscriber = context.Socket(SocketType.SUB))
{
subscriber.Connect("tcp://localhost:5556");
subscriber.Subscribe(string.Empty, Encoding.Unicode);
var interrupted = false;
var sequence = 0L;
var dict = new Dictionary<string, KvMsg>();
Console.CancelKeyPress += (s, e) => { interrupted = true; };
while (!interrupted)
{
KvMsg kvmsg;
try
{
kvmsg = KvMsg.Recv(subscriber);
Console.WriteLine("Received {0}", kvmsg);
}
catch (System.Exception)
{
break;
}
kvmsg.Store(dict);
sequence++;
}
Console.WriteLine(" Interrupted\n{0} messages in\n", sequence);
Console.ReadKey();
}
}
}
}
}