[zeromq-dev] (no subject)

[Paolo Bolzoni]

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