Stack Overflow
Stack Overflow

Questions tagged [jeromq]

JeroMQ is a pure Java implementation of libzmq

JeroMQ is a pure Java implementation of libzmq (http://zeromq.org)

Features:

  • based on zeromq-3

  • tcp:// protocol and inproc:// is compatible with zeromq

  • not too bad performance compared to zeromq 2M messages (100B) per sec Performance

  • exactly same develop experience with zeromq

89 questions
17
votes
2 answers

Is jeromq production ready?

I've used ZeroMQ in the past with with JVM applications via the jzmq library. I am planning on using zeromq on a new project where some of the services are implemented on the JVM. I just discovered jeromq, a pure java implementation of zeromq, and…
Ben Mabey
  • 1,269
  • 10
  • 18
10
votes
1 answer

java.lang.ArrayIndexOutOfBoundsException: 256 with jeromq 0.3.6 version

I am using Jeromq in multithreaded environment as shown below. Below is my code in which constructor of SocketManager connects to all the available sockets first and I put them in liveSocketsByDatacenter map in the connectToZMQSockets method. After…
john
  • 11,311
  • 40
  • 131
  • 251
9
votes
1 answer

How to implement an active & standby queue job-processing system in JeroMQ?

Using ZeroMQ .Context and .Socket instances, I am able to push/pull messages for example below my code for a Queue like setup: ZMQ.Context context = ZMQ.context(1); // Socket to send messages on ZMQ.Socket sender = context.socket(ZMQ.PUSH); …
Abhishek Nayak
  • 3,732
  • 3
  • 33
  • 64
8
votes
3 answers

JeroMQ shutdown correctly

I am wondering how to shutdown JeroMQ properly, so far I know three methods that all have their pro and cons and I have no clue which one is the best. The situation: Thread A: owns context, shall provide start/stop methods Thread B: actual listener…
Sebastian Schlicht
  • 347
  • 2
  • 15
8
votes
2 answers

jeromq: closing context fails

EDIT: solved myself, see below (although I'm not sure if I've stumbled upon a bug here) Using the simple hello-world request-reply example below, closing the context at the end of the program fails: Either it simply hangs at ctx.close() or it throws…
Kevin Bader
  • 327
  • 4
  • 11
6
votes
2 answers

How to transfer a float array (without serializing/deserializing) from Scala (JeroMQ) to C (ZMQ)?

Currently, I am using a JSON library to serialize the data at the sender (JeroMQ), and deserialize at the receiver (C, ZMQ). But, while parsing, the JSON library starts to consume a lot of memory and the OS kills the process. So, I want to send the…
user1274878
  • 1,275
  • 4
  • 25
  • 56
6
votes
1 answer

ZeroMQ, can we use inproc: transport along with pub/sub messaging pattern

Scenario : We were evaluating ZeroMQ (specifically jeroMq) for an event driven mechanism. The application is distributed where multiple services (both publishers and subscribers are services) can exist either in the same jvm or in distinct nodes,…
arunvg
  • 1,209
  • 1
  • 20
  • 31
6
votes
2 answers

Why one might need JeroMQ if it can use JZMQ?

Simple question. Why "porting" zmq on java and call it JeroMQ is good idea?
Artem Vysochyn
  • 73
  • 1
  • 5
6
votes
2 answers

Why is this JeroMQ (ZeroMQ port) benchmark so slow?

I would like to use this library I found, it's a pure java port (not a wrapper) of zeromq. I am trying to test it and while it claims some good numbers, the test I am performing is giving rather poor results and it's even performed locally (client…
Dan
  • 11,077
  • 20
  • 84
  • 119
5
votes
3 answers

How to use jeromq in MATLAB

jeromq is a Java implementation of libzmq. I have a .jar file created from the jeromq source. However, I'm unable to call a class in jeromq from MATLAB. I've used addjavaclasspath and addjavalibrarypath but am still not able to get it working. Does…
kdheepak
  • 1,274
  • 11
  • 22
4
votes
1 answer

Jeromq on android : No virtual method clear()Ljava/nio/ByteBuffer

I'm trying to use jeromq for an android project. I need to connect to another dealer device. Here is my code : ZContext zcontext = new ZContext(1); ZMQ.Socket zsocket = zcontext.createSocket(ZMQ.DEALER); String identity =…
Watanka
  • 131
  • 1
  • 10
4
votes
1 answer

Is jzmq deprecated?

Looking the ZeroMQ bindings. I found that jzmq last release was almost three years ago. Is this binding deprecated? On the other hand there is a native java implementation of ZeroMQ called JeroMQ which is supported by the ZeroMQ community and has a…
Renato Sanhueza
  • 534
  • 7
  • 27
4
votes
1 answer

Getting started with JeroMQ in MATLAB

I am trying to use JeroMQ from MATLAB,by implementing this example ( How to use jeromq in MATLAB ): % Author : Dheepak Krishnamurthy % License : BSD 3 Clause import org.zeromq.ZMQ; ctx = zmq.Ctx(); socket =…
Dan
  • 93
  • 5
4
votes
1 answer

Apache camel: connecting to a ZeroMQ server

I’m trying to connect to a ZeroMQ server using apache camel. I’m using the camel-zeromq component provided by the camel-extra project, but seems that this requires the previous installation of the native ZeroMQ library on the system. Does someone…
Julen
  • 263
  • 1
  • 9
4
votes
1 answer

Zcontext.destroy() hangs instead of terminating all open sockets

I have a server written in Java - (that uses ZeroMQ in REQ-REP and PUB-SUB patterns.) I am wrapping it as a Windows services using the Apache Commons Daemon (prunsrv/procrun) Sometimes the call to ZContext.destroy hangs. I have managed to get stack…
saraf
  • 530
  • 7
  • 22
1
2 3 4 5 6