zeromq Questions

2

I'm using ZeroMQ in Python and C++ in many configurations and I wonder which is the most elegant way to abort a recv() or poll() from another thread (e.g. in case of controlled program termination ...
Aeolotropic asked 26/6, 2015 at 14:51

3

Solved

I'm trying to send an existing dict through zmq ipc socket, I can send a string with this code, but I can't send a dict object import zmq, datetime d = {0: ('356612022462768', 'EVENT', 0, '2012-...
Wacker asked 10/2, 2013 at 12:36

2

Solved

when I read the "Durable Subscribers and High-Water Marks" in zmq guide, it said "The HWM causes ØMQ to drop messages it can't put onto the queue", but no messages lost when I ran the example. Hit ...
Majestic asked 11/11, 2011 at 10:10

3

Solved

Using a ZMQ.SocketType.REP (reply) messaging socket with ZeroMQ, I am receiving messages and then sending an "OK" message back. For now, I'm trying this locally (sending/receiving messages from th...
Shorn asked 5/11, 2011 at 18:43

3

Solved

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...
Hungarian asked 23/1, 2013 at 23:0

3

Solved

I am trying to implement a simple message passing between two applications using NetMQ (a slightly more elaborate description of what I am trying to achieve is below). After a bit of trial and erro...
Neve asked 28/3, 2014 at 14:37

3

I'd like to know what the differences are between the ZeroMQ and WebSockets protocols. I know WebSockets was designed for web browser clients, but I'm assuming it can also be used server to server....
Aubigny asked 31/10, 2014 at 20:7

3

Solved

Here's my script. #!/usr/bin/env python import traceback import sys import zmq from time import sleep print "Creating the zmq.Context" context = zmq.Context() print "Binding the publisher to t...
Swoon asked 5/6, 2011 at 19:13

2

Solved

Is there way to check if JZMQ (java binding of zmq) socket is connected? ZContext zmqContext = new ZContext(); ZMQ.Socket workerSocket = zmqContext.createSocket(ZMQ.DEALER); workerSocket.setIdenti...
Confessedly asked 3/3, 2013 at 10:45

0

I am currently experimenting with ZMQ as a possible message broker for IPCs. Version -> ZMQv4 I am using pebbe ZMQ , a go library over zmq's C library and performing tests. I am rate testing it ...
Oeillade asked 3/7, 2022 at 15:3

1

Is there a way to programatically know when a pgm zeromq socket has stopped forwarding information because the ZMQ_RATE limit has been reached or if it is dropping data because the ZMQ_SNDHWM limit...
Pournaras asked 11/4, 2013 at 15:27

3

Solved

I have an agent-based model, where several agents are started by a central process and communicate via another central process. Every agent and the communication process communicate via zmq. Howeve...
Cark asked 4/7, 2015 at 12:14

3

Solved

We need a lightweight client based messaging solution. We used AMQP, RabbitMQ before, but in C++ we have problems. We would like to choose ZeroMQ with malamuteserver or MQTT ? Our IoT will p...
Guiltless asked 2/6, 2018 at 11:2

3

I'm trying to run a simple piece of code using pyzmq. I am using Python 2.7 and pyzmq 14.5 $ python --version Python 2.7.6 $ sudo find /usr -name "*pyzmq*" /usr/local/lib/python2.7/dist-p...
Pollitt asked 18/9, 2015 at 3:30

2

Solved

I am new to ZMQ. I find ZMQ socket implementation much simpler than winsock. But my doubt is that "can a client created using ZMQ TCP socket talk to conventional TCP server?" in other words Can my ...
Lir asked 26/8, 2014 at 4:49

2

Solved

I am fairly new to ZeroMQ and have been comparing security of messages using the ZeroMQ NuGet package and the NetMQ & NetMQ Security NuGet packages. So far, I have not been able to find a C# v...
Equisetum asked 13/10, 2017 at 6:45

4

Solved

Is it possible to get the total count of subscribers from a PUB socket in zeromq? Thanks!
Firefly asked 30/1, 2013 at 6:33

3

Solved

Q1: What exactly is the difference between using ZeroMQ to send messages to child processes, as compared to the default inter process communication explained here? Q2: For direct process to child ...
Smaragdite asked 20/9, 2015 at 16:45

3

I am getting error on zeromq python while sending strings through ROUTER SOCKET. String type messages are receveid successfully but some times, a unicode message throws exception "Type Error: unico...
Filipino asked 12/3, 2015 at 12:17

3

Solved

My distributed application consists of many producers that push tasks into several FIFO queues, and multiple consumers for every one of these queues. All these components live on a single node, so ...
Compensatory asked 12/2, 2020 at 21:49

2

I'm attempting to do a pub/sub architecture where multiple publishers and multiple subscribers exist on the same bus. According to what I've read on the internet, only one socket should ever call b...
Electromagnet asked 26/8, 2013 at 16:18

3

Solved

I have the following ZMQ script #!/usr/bin/env python2.6 import signal import sys import zmq context = zmq.Context() socket = context.socket(zmq.SUB) def signal_term_handler(signal, fname): ...
Standice asked 6/10, 2014 at 20:16

2

Solved

I have built a WebSockets server that acts as a chat message router (i.e. receiving messages from clients and pushing them to other clients according to a client ID). It is a requirement that the...
Haifa asked 6/9, 2014 at 14:5

6

Solved

Could you give some examples of zeromq?
Woodworker asked 21/12, 2010 at 13:2

1

I am surprised this has not really been asked in detail but for some reason i could not find this question or solution anywhere. It seems to be that a lot of people are having a problem where...
Freshet asked 20/5, 2020 at 12:9

© 2022 - 2024 — McMap. All rights reserved.