//
// Pubsub envelope publisher
//
// Author: Michael Compton, Tomas Roos
// Email: ku.oc.egdeelttil|notpmoc.leahcim#ku.oc.egdeelttil|notpmoc.leahcim, moc.liamg|soorsamotp#moc.liamg|soorsamotp
using System.Text;
using System.Threading;
using ZMQ;
namespace ZMQGuide
{
internal class Program
{
public static void Main(string[] args)
{
using (var context = new Context(1))
{
using (Socket publisher = context.Socket(SocketType.PUB))
{
publisher.Bind("tcp://*:5563");
while (true)
{
// Write two messages, each with an envelope and content
publisher.SendMore("A", Encoding.Unicode);
publisher.Send("We don't want to see this.", Encoding.Unicode);
publisher.SendMore("B", Encoding.Unicode);
publisher.Send("We would like to see this.", Encoding.Unicode);
Thread.Sleep(1000); // avoid flooding the publisher
}
}
}
}
}
}