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.
We are implementing a [Majordomo broker](https://rfc.zeromq.org/spec/7/) derivative that uses in addition to the `ROUTER` also `XPUB` and `SUB` socket types for communicating with external/internal clients and workers. In order to...
I'm trying to use ZAuth to authorise a request reply socket pair where the curveServer is on the REQ socket that 'binds' and waits for the REP socket to connect....
java.lang.NullPointerException at zmq.io.StreamEngine.restartInput(StreamEngine.java:557) at zmq.io.SessionBase.writeActivated(SessionBase.java:276) at zmq.pipe.Pipe.processActivateWrite(Pipe.java:324) at zmq.ZObject.processCommand(ZObject.java:55) at zmq.Command.process(Command.java:75) at zmq.io.IOThread.inEvent(IOThread.java:80) at zmq.poll.Poller.run(Poller.java:273) at java.lang.Thread.run(Thread.java:748)
Will Draft methods such as RADIO/DISH ever be implemented into JeroMQ? I originally wanted to use JZMQ but had problems installing it. If it won't be implemented, how would I...
My zmq application's "reaper-1" thread cost most cpu, so it makes the work thread send messages very slowly. jeromq version: 0.43 java version: 1.8.0_112 
When closing the ZContext I'm receiving the quite unclear message errno 4. What does it mean? The stacktrace: java.lang.IllegalStateException: errno 4 at zmq.Ctx.terminate(Ctx.java:272) at org.zeromq.ZMQ$Context.term(ZMQ.java:627) at org.zeromq.ZContext.destroy(ZContext.java:116) at org.zeromq.ZContext.close(ZContext.java:348) at...
Hello team, Quick question. We have implemented a rather simple req - resp pattern with ROUTER and DEALER sockets. Recently, we have arrived to the conclusion that our messages should...
The jdk version is 1.8.0_51 (64bit) version. OS is windows 7 x64. The jeromq version is 0.3.5. _Note_, the same behavior is not exhibited on OSX. Here is the dump...
I use REQ REP I am trying to send a very large message (- 1Gi) from the server as reply. I print related memory information on the client side process:...
Hi, I read some similar issues, but there is no same problem as me. Issues: The Pub server sends 10000 messages and the Sub client only receives 6873. For Example:...
