flserver2.java

package guide;

import org.zeromq.*;
import org.zeromq.ZMQ.Socket;

//  Freelance server - Model 2
//  Does some work, replies OK, with message sequencing
public class flserver2
{
    public static void main(String[] args)
    {
        if (args.length < 1) {
            System.out.print("I: syntax: flserver2 <endpoint>\n");
            System.exit(0);
        }

        try (ZContext ctx = new ZContext()) {
            Socket server = ctx.createSocket(SocketType.REP);
            server.bind(args[0]);

            System.out.printf("I: echo service is ready at %s\n", args[0]);
            while (true) {
                ZMsg request = ZMsg.recvMsg(server);
                if (request == null)
                    break; //  Interrupted

                //  Fail nastily if run against wrong client
                assert (request.size() == 2);

                ZFrame identity = request.pop();
                request.destroy();

                ZMsg reply = new ZMsg();
                reply.add(identity);
                reply.add("OK");
                reply.send(server);
            }

            if (Thread.currentThread().isInterrupted())
                System.out.print("W: interrupted\n");
        }
    }
}