My understanding is that connections are created asynchronously in a background
thread, and that file descriptors are used to communicate between your threads
and the zeromq io threads.
Does it do the same thing if you put a sleep in there, giving the zeromq io
thread time to close the file des
Hi,
We are trying to use zeroMQ's PUB SUB architecture for publishing 100K
messages to a list of subscribers. But we would need to authenticate the
subscribers and store this list for tracking purpose. What is the best way
to handle this? Can we use curvezmq? if so, how to bind it with JZMQ? Are
t
Many attempts to connect()/disconnect() will eventually fail with EINVAL.
It seems that the number of successful connect()/disconnect() pairs is somewhat
correlated
with the number of allowed open file descriptors for the process, as if some
descriptors are
not closed:
$ python dis.py
RLIMIT_N
Unbind an inproc socket doesn't work in 3.2.3:
>>> import zmq
>>> zmq.zmq_version()
'3.2.3'
>>> ctx = zmq.Context()
>>> socket = ctx.socket(zmq.PAIR)
>>> addr = "inproc://test"
>>> socket.bind(addr)
>>> socket.unbind(addr)
Traceback (most recent call last):
File "", line 1, in
File "socket.py
filtering happens at the publisher side means when SUB1.subscribe("C") and
SUB2.subscribe("D"), the publisher won't send "D" to SUB1, nor "C" to SUB2
2013/8/22 Roy Liu
> Hi, Luke
>
> In ZMQ 3.x, if publisher filter the message first and sent the filtered
> message to the subscriber or not?
> i
Hello,
after building the stuff under Windows I tried to make the whole stuff
working under Ubuntu also. But the application exits pretty early with
the following message (within a VirtualBox Ubuntu LTS 12.04):
pending_bytes == 0 (pgm_receiver.cpp:142)
Now I wanted to build ZMQ 2.2.0 on that p
