3,333 questions
Score of 0
1 answer
142 views
How to publish std::vector<Eigen3f> using zmq
I’m working on a ZeroMQ PUB/SUB setup where the publisher sends point cloud data captured from an Intel RealSense depth camera, and the subscriber reconstructs it for further processing.
In my ...
Score of 1
1 answer
128 views
How to reconnect zeromq client to server?
I have just started using the Python ZeroMQ library, pyzmq==27.1.0.
I am running on a Raspberry Pi 5 (debian 12 - bookworm)
I want to make sure my client reconnects if my server stops and restarts. ...
Score of 0
1 answer
87 views
how to set zmq subscriber to buffer no msg
How to maker the zmq pub/sub subscriber buffers no msgs at all?
import zmq
import time
PUB_ADDR = "tcp://localhost:12345"
ctx = zmq.Context()
socket = ctx.socket(zmq.PUB)
socket.set_hwm(1)
...
Score of 1
2 answers
94 views
confusing zmq termination race condition in whitepaper
I'm looking over this explanation of a race condition during the zmq termination procedure.
Here is the relevant part from the page.
In the following diagram we see a race condition where the main ...
Score of 1
1 answer
91 views
How to configure Laravel Ratchet WebSocket + ZMQ host/port for local, development, and production environments?
I’m building a Laravel project that uses a WebSocket server with Ratchet and ZeroMQ (ZMQ) for broadcasting events.
In my local environment, the setup looks like this:
// App\Console\Commands\...
Score of 1
1 answer
72 views
Correct pattern to process ZeroMQ messages using Goroutines
I am implementing a Zero MQ message listener service in Go, and I am struggling to find the most idiomatic pattern of processing those messages and storing them in a DB using Goroutines. I am ...
Score of 0
1 answer
61 views
Can I safely have a sender use zmq_send and receiver use zmq_msg_recv?
I have one module where the developer used zmq_send and another module where the developer used zmq_msg_recv. These are supposed to talk to each other. As far as I can tell, zmq_send is just a wrapper ...
Score of 1
1 answer
97 views
ZMQ Dynamic Discovery with XPub-XSub
I'm attempting to implement dynamic discovery of networked "nodes" using ZMQ's XPub-XSub pattern. Every example I can find online is limited to a single machine - using localhost for the IP ...
Score of 2
1 answer
62 views
Why is the requester and responder socket string different in zmq_bind vs zmq_connect?
I have just started studying the ZeroMQ messaging library from Chapter 1 of the guide (available here). While I understand the well-written examples, I don't get one small point of the syntax: ...
Score of 3
3 answers
255 views
How to gracefully terminate a socket server?
If I have a server function that is listening to a port in an infinite loop, how do I stop it? If I do Ctrl+C it terminates the process and the program does not get a chance to destroy the socket ...
Score of 1
0 answers
214 views
srsUE on FPGA not connecting to srsRAN
I'm running srsUE on FPGA, buildroot with 2 CPUs and 1G memory. srsRAN is running on my laptop, ubuntu 22. I use dockerized version of 5gc.
srsUE and srsRAN connected through ZMQ and on a local ...
Score of 0
0 answers
170 views
How to launch ECS task instances dynamically using C#?
I have a micro-services application that I am deploying to AWS using ECS Fargate. Most of the containers can be deployed as long running tasks in a service. However, I need to spin up new containers ...
Score of 1
0 answers
159 views
Setup zeromq client-server between Windows and WSL
I'm using ZeroMQ to set up a client-server communication system where the server runs on WSL and the client runs on Windows. For testing purposes, I'm using the default client-server example code in C ...
Score of 0
1 answer
106 views
Create NetMQ Socket on one thread and operate on another?
I understand that NetMQ sockets are not thread safe. I'm trying to understand the exact boundaries of this. Must all access to a socket (creation, connect/bind and send/receive) be on the same thread? ...
Score of 1
1 answer
147 views
Using ZMQ, which pattern and framework to use in such a scenario ? Two computers, bidirectional, not knowing which starts first
My application is separated in two computers (A which contains some GUI and B which contains some complex processing).
Here are some constraints:
PROBLEMS
Both computers need to communicate between ...