I recently tried something similar. My aim was to have a main publisher socket 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. forward from the sub skt to the main pub skt. I recieved no errors, but none of the messages got delivered to the other sub skts that subscribed.
I managed to implement my own queue in which I forward all messages, and then 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
