//
// Custom routing Router to Papa (ROUTER to REP)
//
// 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
{
// We will do this all in one thread to emphasize the sequence
// of events…
public static void Main(string[] args)
{
using (var context = new Context(1))
{
using (Socket client = context.Socket(SocketType.ROUTER), worker = context.Socket(SocketType.REP))
{
client.Bind("inproc://routing");
worker.StringToIdentity("A", Encoding.Unicode);
worker.Connect("inproc://routing");
// Wait for the worker to connect so that when we send a message
// with routing envelope, it will actually match the worker…
Thread.Sleep(1000);
// Send papa address, address stack, empty part, and request
client.SendMore("A", Encoding.Unicode);
client.SendMore("address 3", Encoding.Unicode);
client.SendMore("address 2", Encoding.Unicode);
client.SendMore("address 1", Encoding.Unicode);
client.SendMore("", Encoding.Unicode);
client.Send("This is the workload", Encoding.Unicode);
// Worker should get just the workload
ZHelpers.Dump(worker, Encoding.Unicode);
// We don't play with envelopes in the worker
worker.Send("This is the reply", Encoding.Unicode);
// Now dump what we got off the ROUTER socket…
ZHelpers.Dump(client, Encoding.Unicode);
}
}
}
}
}