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 = c
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:
>
> Send
Here is the full code... You should be connecting to the sender and then
subscribing to all the messages.
Sender:
sender.bind("tcp://127.0.0.1:5559")
...
sender.send_json(message)
Device:
context = zmq.Context(1)
incoming = context.socket(zmq.SUB)
incoming.connect("tcp:
Joshua Foster gmail.com> writes:
> > 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.
