jeromq
jeromq copied to clipboard
JeroMQ is a pure Java implementation of the ZeroMQ messaging library, offering high-performance asynchronous messaging for distributed or concurrent applications.
I'm attempting to create an instance of my ZMQ stack for each unit test in my test suite. But I get problems when I rapidly open/close sockets and contexts. Some...
Setting the linger period for socket shutdown seams to not work. When doing a ``` java socket.setLinger(timeout); socket.close() ``` the `socket.close()` will not wait the linger period if there are...
Hi, We are having an issue where when we stress a JeroMQ Context with simultenous requests, it seems that the emptySlots deque is not being replenished correctly, so you end...
i use jeromq 0.4.3 with jdk 8. sometimes Poller.run get 100% cpu usage without any message. i add some debug info in the Poller and find that `rc = selector.select(timeout);`...
Spun off of #472. See that issue for some initial discussion. I think this should probably end up being a separate repo within the zeromq org, since it will encompass...
#674 made me start to question why we throw unchecked exceptions. It seems to me like we might want to only throw checked exceptions, because that way, the library user...
https://github.com/zeromq/libzmq/commit/759d453368479257638e6b09e1febe19fbef2a3d There're significant change on the monitoring of various events.
I'm going to keep this intentionally very generic because I am looking for generic advice. Our program has a zmq context. When createSocket(int type) is called for the first time...
I have a server with a DEALER socket and I call `bind` on it. Then i have a client that `connects` to my server's address, using a DEALER socket as...