[zeromq-dev] Basic forwarder question
dlg at dangould.com
Tue May 3 00:11:55 CEST 2011
I'm a ZeroMQ newbie, but couldn't find an answer to this via the docs or
list archives (sorry if I missed it).
I've been using a pub/sub connection. It works fine. I was using:
receiver = context.socket(zmq.SUB)
Now, I want an arbitrary number of publishers and an arbitrary number of
subscribers. So, I run a forwarder:
context = zmq.Context(1)
publishers = context.socket(zmq.SUB) # Also tried flipping PUB and SUB
subscribers = context.socket(zmq.PUB)
zmq.device(zmq.FORWARDER, publishers, subscribers)
and made my sender connect to 5555 instead of binding 5559 (and have my
receiver connect to 5556).
I don't get any messages. Is this how a forwarder should work?
More information about the zeromq-dev