Here's a tarball of a working version from my Mac. Apologies for any coding oversights, it's late.
zmq_pubsub.tar
Description: Unix tar archive
BEWARE : stupid Mac resource forks included in the tarball Please let me know if you have issues.. Best, Matt On Jul 16, 2010, at 9:05 PM, Dmitri Toubelis wrote:
I've abandoned this idea for now, it seems easier to implement my ownbroker, then try to make ZMQ to what it is not designed to do. It would be nice to see this feature in a future releases though. It is not a classical PUB/SUB pattern but I think it is way more powerful. Can I suggest it as afeature request? It should be rather straightforward fix. -----Original Message----- From: [email protected][mailto:[email protected]] On Behalf Of david starkweatherSent: July 16, 2010 8:42 PM To: 0MQ development list Subject: Re: [zeromq-dev] PUB/SUB with multiple publishersI recently tried something similar. My aim was to have a main publishersocket in the main thread, and then each worker thread have a another publisher socket. I would then have a pipe between the worker sockets and a sub socket in the main thread. It is my understanding that the forwarder device is supposed to work for this scenario - i.e. forwardfrom the sub skt to the main pub skt. I recieved no errors, but none ofthe messages got delivered to the other sub skts that subscribed.I managed to implement my own queue in which I forward all messages, andthen have one publisher thread to just publish messages. I have only been able to get the pub/sub mechanism to work when there is just one publisher. If anyone has any alternate ideas, I'd be interested. thanks. Grant Starkweather On Fri, 2010-07-16 at 13:34 -0400, Dmitri Toubelis wrote:I have a scenario when I need to use PUB/SUB scheme with multiple publishers. Is it possible to do with "inproc" transport? Here is what I tried: - create PUB socket and bind it to "inproc://pipe" endpoint- create another PUB socket and connect it to the same "inproc:// pipe"endpoint - create SUB socket for each subscriber and connect them to thre "inproc://pipe" endpoint. - publish message using second publisher. I'm getting no error, but message is not getting delivered to subscribers. Am I doing something wrong? Any help is appreciated. _______________________________________________ zeromq-dev mailing list [email protected] http://lists.zeromq.org/mailman/listinfo/zeromq-dev_______________________________________________ zeromq-dev mailing list [email protected] http://lists.zeromq.org/mailman/listinfo/zeromq-dev _______________________________________________ zeromq-dev mailing list [email protected] http://lists.zeromq.org/mailman/listinfo/zeromq-dev
_______________________________________________ zeromq-dev mailing list [email protected] http://lists.zeromq.org/mailman/listinfo/zeromq-dev
