Ronald, > Do i need to close forwarder again and than start after each message sent by > the publisher, or can i do something like i can start the forwarder first and > next publisher check if the forwarder is running than just leverage the > forwarder to send some messages to the subscriber. No you just leave the forwarder running. That's the magic of using a forwarder with pub-sub sockets. But you should probably change how the forwarder device is configured. The way I use the forwarder is to have it bind both the incoming and outgoing sockets and then have the producers and consumers connect to the forwarder; that way once the forwarder is running, producer and consumer processes can start and stop without crashing the other. See: https://gist.github.com/2136666#comments
-- Cornelius Toole Sent with Sparrow (http://www.sparrowmailapp.com) On Tuesday, March 20, 2012 at 4:35 AM, Symbian Projects wrote: > Hello All, > > In one of my past threads i got the zmq device forwarder working, now my > exact use case is like i have arbitrary no of publishers and subscribers. > > First i start the ZMQ forwarder device, than i am starting the subscribers > and than a single publisher to send the message. > > My objective is there are no of publishers who should be able to send > messages to the connected subscribers, now how this can happen with a > FORWARDER. > > Do i need to close forwarder again and than start after each message sent by > the publisher, or can i do something like i can start the forwarder first and > next publisher check if the forwarder is running than just leverage the > forwarder to send some messages to the subscriber. > > I hope my question is clear. > > Thanks a Lot for reply. > Ronald > > > _______________________________________________ > zeromq-dev mailing list > [email protected] (mailto:[email protected]) > http://lists.zeromq.org/mailman/listinfo/zeromq-dev > >
_______________________________________________ zeromq-dev mailing list [email protected] http://lists.zeromq.org/mailman/listinfo/zeromq-dev
