import org.zeromq.ZMQ;

//
//  Task worker in Java
//  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
//
//  Nicola Peduzzi <thenikso@gmail.com>
//
public class taskwork {

	public static void main(String[] args) throws Exception {
		ZMQ.Context context = ZMQ.context(1);

		//  Socket to receive messages on
		ZMQ.Socket receiver = context.socket(ZMQ.PULL);
		receiver.connect("tcp://localhost:5557");

		//  Socket to send messages to
		ZMQ.Socket sender = context.socket(ZMQ.PUSH);
		sender.connect("tcp://localhost:5558");

		//  Process tasks forever
		while (true) {
			String string = new String(receiver.recv(0)).trim();
			long nsec = Long.parseLong(string) * 1000000;
			//  Simple progress indicator for the viewer
			System.out.flush();
			System.out.print(string + '.');

			//  Do the work
			Thread.sleep(nsec);

			//  Send results to sink
			sender.send("".getBytes(), 0);
		}
	}
}