vJine.ZMQ

    [Serializable]
    public class BizEntity {
        [XmlAttribute]
        public string X { get; set; }
        [XmlAttribute]
        public int I { get; set; }
    }

    BizEntity X = new BizEntity() { X = "Привет мир", I = 2015 };

    ZmqContext context = new ZmqContext();
    ZmqSocket zmqServer =
        context.Bind(ZmqRole.PUB, "tcp://*:4041");
    ZmqSocket zmqClient = context
        .Connect(ZmqRole.SUB, "tcp://127.0.0.1:4041");

    zmqServer.Send("Привет мир");
    string msg = zmqClient.Receive<string>();

    zmqServer.Send<BizEntity>(X);
    BizEntity r = zmqClient.Receive<BizEntity>();

    X.I += 1; X.X += ";HoHo";
    zmqServer.Send<BizEntity>(X);
    zmqClient.Receive<BizEntity>(r);