Hi, and thanks for the wonderful library.

I'm trying to make my REQ/REP app multi-threaded on the server.  I have two
sockets on the server both REP. One is for 'reads', the other 'writes'.

I would like to make reads multithreaded, but keep writes serialized so I
need to distinguish between the types, hence the two REP sockets and the
poller to process them fairly.

I have tried to forward from the Poller to a multithreading ROUTER/DEALER
as shown in the guide, but am doing something wrong. When I create my
queuing proxy between ROUTER and DEALER, the server hangs without an error.
Here is the code.  http://pastebin.com/5KKkvaBi

In the code (snippet shown below) the first println executes and the second
does not.

        System.out.println("About to start");
        ZMQ.proxy(readRouter, readWorkers, null);
        System.out.println("Started");

Any help would be hugely appreciated.

Thanks
_______________________________________________
zeromq-dev mailing list
zeromq-dev@lists.zeromq.org
http://lists.zeromq.org/mailman/listinfo/zeromq-dev

Reply via email to