[zeromq-dev] Basic forwarder question

[Joshua Foster]

add:
    publishers.setsockopt(zmq.SUBSCRIBE, "")

Joshua
On 5/2/2011 6:11 PM, Dan Gould wrote:
> Hi,
>
> 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:
>
> Sender:
>       sender.bind("tcp://127.0.0.1:5559")
> ...
>       sender.send_json(message)
>
> Receiver:
>       receiver = context.socket(zmq.SUB)
>       receiver.connect("tcp://127.0.0.1:5559")
>       receiver.setsockopt(zmq.SUBSCRIBE, "")
>
>
> 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
> publishers.bind("tcp://127.0.0.1:5555");
> subscribers = context.socket(zmq.PUB)
> subscribers.bind('tcp://127.0.0.1:5556')
>
> 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?
>
> Thanks.
> _______________________________________________
> zeromq-dev mailing list
> zeromq-dev at lists.zeromq.org
> http://lists.zeromq.org/mailman/listinfo/zeromq-dev