轻量级消息队列、服务总线ZBUS之C#.NET客户端

RemotingClient client = new RemotingClient("127.0.0.1:15555");

Producer producer = new Producer(client, "MyMQ", MessageMode.MQ);
        
Message msg = new Message();
msg.Topic = "qhee";
msg.SetBody("hello world from C# {0}", DateTime.Now);
msg = producer.Send(msg, 10000); 

RemotingClient client = new RemotingClient("127.0.0.1:15555");
Consumer csm = new Consumer(client, "MyMQ"); 
while (true)
{
    Message msg = csm.Recv(10000);
    if (msg == null) continue;
    Console.WriteLine(msg);
}