Dear zeromq list, I need to send a possibly large message to a set of recipients. I do not need to worry about disappearing nodes, but recipients and sender can appear in any order.
I started writing initially in C using the syncpub and syncsub as base. The first prototype seems work fine. syncpub.c http://paste2.org/p/2004863 syncsub.c http://paste2.org/p/2004864 The idea is simple: subscribers await for the publisher and the publisher await for all subscribers. Now, the project where I need to use this uses Java so I downloaded, compiled and installed jzmq and tried the hwclient java example to ensure that jzmq were installed fine. Once the example worked fine I wrote those two classes that follow the same idea of two C files: SyncPub.java http://paste2.org/p/2004819 SyncSub.java http://paste2.org/p/2004814 Unfortunately they do not work. It seems the subscriber cannot read any message. To me the classes seems a translation in Java of the C files, so I have no idea of the problem. I tried listening the wire using wireshare and in the Java version there are only few upd packets while in the C version there are plenty. Once again I am clueless. I am on linux 3.3.4 and I am using ØMQ 2.2.0 compiled with pgm support. jzmq has been cloned from github yesterday. (really there is no jzmq in any public maven repository?) What can I try? Thanks _______________________________________________ zeromq-dev mailing list [email protected] http://lists.zeromq.org/mailman/listinfo/zeromq-dev
