zeromq

ActiveMQ or RabbitMQ or ZeroMQ or...

We'd be interested to hear any experiences with the pros and cons of ActiveMQ vs RabbitMQ vs ZeroMQ. Information about any other interesting message queues is also welcome. ...

Detecting slow readers with zmq(zeromq)

I'm trying to replace a small homegrown messaging system, and are playing around a bit with zmq . I'll be needing to detect slow readers, and boot/disconnect them - slow readers pretty much meaning a particular consumer whos queue size is above a certain threshold. So far it seems zmq blocks every consumer if one of them is a bit slow (...

Best language for ZeroMQ on OpenVMS?

We are looking at developing several applications using ZeroMQ as the messaging infrastructure. The main OS will be OpenVMS running on HP Integrity Servers. Does anyone have any suggestions for the best language to use? C/C++, Java, COBOL? ...

zeromq/AMQP plugable?

[1] I was reading through the AMQP standard, and it seems that there is a clear separation between the exchange, queue and binding component. However, looking at the zeromq docs, it doesn't seem as if zeromq allows you to plug in your own exchange/queue/bindings implementation. [2] Also, is there any AMQP framework available where I don...

Subscribe Authentication With ZeroMQ

I am having a hard time understanding the ZeroMQ messaging system, so before I dive in, I wanted to see if anyone knew if what I want to do is even possible. I want to setup a pubsub server with ZeroMQ that will publish certain streams of data and to subscribe to some of those streams, a user must authenticate to see if they have acces...

How to set a zmq socket timeout

I've got client and server applications using zmq in the ZMQ_REQ context. What I'm experiencing is that when the server component goes down or is unavailable, the client will wait until it is available to send its message. Is there a way to set a max wait time or timeout at the client level? ...

How do CPG of Corosync, ZeroMQ, and Spread compare for messaging?

I'm interested in: Performance Latency Throughput Resource usage (CPU, memory, ...) High availability No single point of failure Features Transport options Routing options Stability Community Active development Widely used Helpful mailing list, forum, IRC channel, ... Ease of integration with my current codebase Gotchas maybe A...

DDS vs AMQP vs ZeroMQ

Hi, I wanted a feedback on whether my evaluations and concerns are correct. I have been reseaching the three, Data Distribution Service, AMQP and ZeroMQ for sometime now for building a data transport layer in a datacenter. All the three look promising, yet i encountered some blocking issues in few. To give a context, my requirements a...

Do you know any projects where ZeroMQ was used? Both success and failure stories are valuable

I'm interested in using ZeroMQ in a project, but I'd like to hear about other's experience with it. I did some searching but found only mongrel2 project. Have you heard about other projects where it is used? What companies use ZeroMQ in production? ...

Pure java ZeroMQ clients?

I am trying to use ZeroMQ's pub sub messaging, but the client side requires the code to be all Java. I understand that ZeroMQ has a Java binding but that still relies on a c library, therefore I am unable to use it. Is there a ZeroMQ client I can use to connect to the server, or is the implementation simple enough for me to do myself? ...

How do I compile jzmq for ZeroMQ on OSX?

Trying to follow the directions from: http://github.com/zeromq/jzmq I installed pkg-config using Homebrew and then I run the following commands: ./autogen.sh ./configure The configure fails with: checking how to hardcode library paths into programs... immediate ./configure: line 15263: syntax error near unexpected token `newline' ./c...

Compile C lib for iPhone

I'm trying to compile ZeroMQ C binding in order to be able to use it on iPhone, here is my configure options: ./configure --host=arm-apple-darwin --enable-static=yes --enable-shared=no CC=/Developer/Platforms/iPhoneOS.platform/Developer/usr/bin/arm-apple-darwin10-gcc-4.2.1 CFLAGS="-pipe -std=c99 -Wno-trigraphs -fpascal-strings -O0 -Wre...

How should a ZeroMQ worker safely "hang up"?

I started using ZeroMQ this week, and when using the Request-Response pattern I am not sure how to have a worker safely "hang up" and close his socket without possibly dropping a message and causing the customer who sent that message to never get a response. Imagine a worker written in Python who looks something like this: import zmq c ...

Blocking operations and ZeroMQ

Hi, I'm designing a distributed system in which a single-threaded server processes perform a CPU intensive operation. These operations are triggered by ZeroMQ network messages. If the single-threaded process is performing the CPU intensive work, will the I/O (ZeroMQ sockets) block? Thanks! ...

Append-only server performance

Hi, I'm building a small web server for learning purposes. For each incoming POST request I'm planning to append the content to a file. I'm using ZeroMQ sockets for communicating with the file-append process. Do I need to take special care with the file operations (fopen, fseek)? Considering a typical Amazon EC2 instance and that eac...

ZeroMQ / ØMQ / 0MQ how to get started?

I am trying to use ZeroMQ / ØMQ / 0MQ (which ever you prefer) on Windows using C# Binding. Is there any beginner materials out there? Do I need to register ZeroMQ DLL on Windows or something in order to run the C# Binding samples (local_lat / remote_lat)? Updated: After a few hours I've got zeromq / ruby working on Ubuntu 10.04. I've le...

ZeroMQ based distributed system

Hi, In a distributed system with the following data flow: The client sends a message for a random node in the distributed system. The node checks if the operation can be performed by him. If not, sends the message to other node. And the process follows until the correct node. So the system has the following flow: client -> nodeX ->...

ZeroMQ design decisions

In a REQ/REP socket, if the socket send a request to a dead (disconnected) node the message isn't delivered and stays in a message queue occupying memory. How can one clean these undelivered messages (let's say, messages that are in the queue for more than 1 minute)? Thanks! ...

Using zeromq in a distributed load pipeline, can I get the address of the last server a message was sent to

If I set up a pipeline which distributes load across a cluster, I would like to log where the messages get sent. This is what I have in mind (python): import zmq context = zmq.Context() socket = context.socket(zmq.DOWNSTREAM) socket.connect("tcp://127.0.0.1:5000") socket.connect("tcp://127.0.0.1:6000") msg = "Hello World\0" connection...

High-level differences between node.js and ZeroMQ?

Excuse my ignorance, but what is the high-level overview of (something like) node.js versus ZeroMQ? ...