jeromq
jeromq copied to clipboard
zeromq
JeroMQ is a pure Java implementation of the ZeroMQ messaging library, offering high-performance asynchronous messaging for distributed or concurrent applications.
The context is that I'm writing a [Clojure JeroMQ wrapper library](https://github.com/daveyarwood/ezzmq) and translating the zguide examples as I go. When I translated the multi-threaded server example (a single process with...
We have one publisher and two subscriber applications utilizing ZeroMQ's Pub-Sub pattern without implementing any heartbeat mechanism. One application is running on (10.159.251.23) that publishes messages on port 6666: `publisher.publisherSocket...
We are experiencing an issue where occasionally, messages are taking just over 30 seconds to send on a simple request socket. This seems to occur when the system has many...
Our application reading messages from a C++ application using zmq/cppzmq (version 4.2.2). It is reading approx 10-80 messages per second, and after a couple of days of running will get...
It is not obvious, but I recently find out that **the IOThread has to drain all commands in its mailbox in order to be signaled again for new commands**. This...
The WAITING_FOR_DELIMITER state is not being handled in [Pipe::processPipeTerm()](https://github.com/zeromq/jeromq/blob/b0103265917351387d4d0de8ac8d2daf6bb5c80e/src/main/java/zmq/pipe/Pipe.java#L370) when the function is being called a second time in response to an anomalously termination of the remote host, for example,...
Hi, I have hit the following issue: If I set: ``` requester.setReqRelaxed(true); requester.setReqCorrelate(true); ``` on a REQ socket using tcp the socket no longer receives any data. The full example...
I'm trying to bind a subscriber socket, and running the following test case. However, the code blocks on recvStr(): ``` ZContext ctx = new ZContext(1); ZMQ.Socket rcvr = ctx.createSocket(ZMQ.SUB); rcvr.bind("inproc://control");...
Nowadays, we encounter the problem of socket timeout due to the lack of data for a long time in use.I want to reconnect the socket by setting the heartbeat time...
Hello, I want to send and receive data from Matlab and Metatrader 5 on Windows 10. According to this post, Jeromq ist is the easiest route to go: https://de.mathworks.com/matlabcentral/answers/269061-how-do-i-integrate-zeromq-library-with-matlab-i-want-my-matlab-program-to-be-a-subscriber-of-zeromq 1....
