//
// Task worker
// Connects PULL socket to tcp://localhost:5557
// Collects workloads from ventilator via that socket
// Connects PUSH socket to tcp://localhost:5558
// Sends results to sink via that socket
//
// Author: Mike Sheridan, Tomas Roos
// Email: moc.gnitlusnockroftsew|ekim#moc.gnitlusnockroftsew|ekim, moc.liamg|soorsamotp#moc.liamg|soorsamotp
using System;
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 receiver = context.Socket(SocketType.PULL), sender = context.Socket(SocketType.PUSH))
{
receiver.Connect("tcp://localhost:5557");
sender.Connect("tcp://localhost:5558");
while (true)
{
string task = receiver.Recv(Encoding.Unicode);
// Simple progress indicator for the viewer;
Console.WriteLine("{0}.", task);
int sleepTime = Convert.ToInt32(task);
Thread.Sleep(sleepTime);
// Send 'result' to the sink
sender.Send("", Encoding.Unicode);
}
}
}
}
}
}