Skip to main content

Questions tagged [zeromq]

ZeroMQ (ZMQ, 0MQ, ØMQ) is a high-performance asynchronous messaging library aimed at use in scalable, distributed and/or concurrent applications.

Filter by
Sorted by
Tagged with
11 votes
1 answer

Do not share same socket between two threads at the same time

I have a code in which I am dealing with sockets and I need to make sure that I don't share same socket between two threads. In my below code, I have a background thread which runs every 60 seconds ...
david's user avatar
  • 1,947
5 votes
2 answers

Send records and retry them if acknowledgement is not received

I am working on a project where I need to consume lot of records and then I am sending these records to some other system which uses zeromq. Here is the flow: Store all the incoming records in a CHM ...
david's user avatar
  • 1,947
3 votes
1 answer

Haskell zmq & protobuf message forwarding

I wrote a test program (and first "real" Haskell program!) that receives a zmq request on 1 socket, and forwards part of that message to another socket. There are a 2 things I specifically don't like:...
Charles L.'s user avatar
10 votes
1 answer

Sync eye movements with external events

This solution was used to synchronize events between two applications: An eye tracking software, Python, and a stimulus control software, object Free Pascal/Delphi. It avoided a rewrite of the ...
cpicanco's user avatar
  • 499
6 votes
1 answer

Efficiently using ZeroMQ sockets in Java

I am working on multithreading project and I am using ZeroMQ socket to send the data as a byte array. Below is my example which works fine. I'm opting for code review to see whether it can be improved ...
arsenal's user avatar
  • 2,167
5 votes
1 answer

Lazy Pirate Request Response pattern using zeromq and C#/.NET bindings

I'm a zeromq newb and have implemented the REQ/RES Lazy Pirate pattern with C#. It's essentially a port from the C example given in the documentation. It's harnessed by tests, and seems to be work to ...
stantona's user avatar
  • 183