Publisher

using System;
using System.Collections.Generic;
using System.Text;
using ZMQ;

namespace HwmTest
{
    class Program
    {
        static void Main(string[] args)
        {
            Context context = new Context(1);

            Socket pubSocket = context.Socket(SocketType.PUB);
            pubSocket.HWM = 10;
            pubSocket.Bind("tcp://*:5555");

            int msgId = 0;

            while (true)
            {
                string msg = (++msgId).ToString();

                pubSocket.Send(msg, Encoding.UTF8);
            }
        }
    }
}