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. ...
rabbitmq
Stomp Broadcast with Rabbitmq and Python
Im trying to move a system from using morbid to rabbitmq, but I cannot seem to get the same broadcast behaviour morbid supplied by default. By broadcast I mean that when a message is added to the queue, every consumer recieves it. With rabbit, when a message is added they are distributed round robin style to every listener. Can anyone t...
Check RabbitMQ queue size from client
Does anyone know if there's a way to check the number of messages in a queue from a client application? Thanks. BTW, I'm using .NET client libraty. ...
Phusion Passenger + Workling + RabbitMQ
Hi everyone, I am trying to deploy a RoR app that does some asynchronous task. I use workling for that and the message queue is RabbitMQ. This combination worked flawlessly with Starling but we decided to change the MQ for Rabbit. I read somewhere that I should include the following code in my environment.rb require 'mq' if defined?(P...
Should I use Celery or Carrot for a Django project?
I'm a little confused as to which one I should use. I think either will work, but is one better or more appropriate than the other? http://github.com/ask/carrot/tree/master http://github.com/ask/celery/tree/master ...
Where to put message queue consumer in Django?
I'm using Carrot for a message queue in a Django project and followed the tutorial, and it works fine. But the example runs in the console, and I'm wondering how I apply this in Django. The publisher class I'm calling from one of my models in models.py, so that's OK. But I have no idea where to put the consumer class. Since it just sit...
In a FIFO Qeueing system, what's the best way the to implement priority messaging.
For message-oriented middleware that does not consistently support priority messages (such as AMQP) what is the best way to implement priority consumption when queues have only FIFO semantics? The general use case would be a system in which consumers receive messages of a higher priority before messages of a lower priority when a large ...
Idempotency Barrier for messaging
A recent presentation I saw regarding RabbitMQ mentioned the use of something called an "idempotency barrier" for message de-duplication. Is this just a fancy name for a message conflator or is it something more specific. If so, what exactly is it? A google search yielded results which are mostly related to RabbitMQ, with little explanat...
How to set timeout detection on a RabbitMQ server?
I am trying out RabbitMQ with this python binding. One thing I noticed is that if I kill a consumer uncleanly (emulating a crashed program), the server will think that this consumer is still there for a long time. The result of this is that every other message will be ignored. For example if you kill a consumer 1 time and reconnect, th...
How do I properly snapshot an EBS volume with a RabbitMQ instance running?
I'm using RabbitMQ on an EC2 instance and I have the Mnesia tables on an EBS volume, so when I snapshot it and try to launch another instance with the same data, it appears that the table is in use by another RabbitMQ instance. Is the only way to get around this to shut RabbitMQ down for the flush/snapshot and then start it back up once...
Async / Enterprise Messaging for PHP Apps
What messaging platform would be the best choice for asynchronous message queuing (publish, consume) between PHP and Java apps? I have looked at RabbitMQ, ActiveMQ, OpenAMQ, Tibco Rendezvous, and Websphere MQ. Persistence is required. I love the idea of AMQP and using an open protocol, but I've heard of stability issues with RabbitMQ, wh...
problems with rabbitmq cluster across 2 ubuntu 9.04 machines
I keep getting unable_to_contact_cluster_nodes error Has anyone seen this earlier and resolved it? I am using rabbitmq-server 1.5.4 installed using ubuntu repositories. I have a hunch that this is something to do with ufw or some other network security measure, enabled by default in ubuntu, that is preventing connections. The machine ...
Benefits of Commercial Messaging Middleware vs Open Source
I've been evaluating several opensource message queue technologies, such as RabbitMQ, ActiveMQ, OpenAMQ, etc. My question is, what benefits are gained by using a commercial technology such as Tibco EMS, WebSphereMQ, Sonic, etc. instead of something like Active or Rabbit? PHP will be the primary language involved, although Java systems wi...
Unique Messages per Queue in AMQP?
This is similar to this other question but with a bit of a twist: I read in the specification that the message-id for AMQP messages should be set by the application itself, so in theory I could use that to guarantee a certain degree of uniqueness, right? My main question is now: In what scope is that message-id garantueed to be unique? ...
Workling processes multiplying uncontrolably
Hello there. We have a rails app running on passenger and we background process some tasks using a combination of RabbitMQ and Workling. The workling's worker process is started using the script/workling_client command. There is always only one worker process started, and the script/workling_client has a :multiple => false options, thus ...
How to wait for messages on multiple queues using py-amqplib
I'm using py-amqplib to access RabbitMQ in Python. The application receives requests to listen on certain MQ topics from time to time. The first time it receives such a request it creates an AMQP connection and a channel and starts a new thread to listen for messages: connection = amqp.Connection(host = host, userid = "guest", pass...
Multiple consumer one queue
Is it possible to make multiple consumers to share one single queue in RabbitMQ? I am currently using this php library to work with RabbitMQ, from what I observe, although I have 2 identical instances of a consumer script running, but only one would respond to the message passed... ...
RabbitMQ gives a "access refused, login refused for user" error when attempting to follow the celery tutorial
I'm attempting to follow the celery tutorial, but I run into a problem when I run python manage.py celeryd: my RabbitMQ server (installed on a virtual machine on my dev box) won't let my user login. I get the following on my Django management console: [ERROR/MainProcess] AMQP Listener: Connection Error: Socket closed. Trying again in 2...
requeue a sweatshop job in RabbitMQ
I am working on a Rails application where customer refunds are handed to a Sweatshop worker. If a refund fails (because we cannot reach the payment processor at that time) I want to requeue the job. class RefundWorker < Sweatshop::Worker def process_refund(job) if refund Transaction.find(job[:transaction]).update_attributes(:sta...
What's the difference between Mozilla Public License 1.1 (MPL) and Apache License?
There are a couple of threads talking about license issue. Mostly focusing on GPL/LGPL/BSD. I am trying to use RabbitMQ in commercial applications, which is licensed under Mozilla Public License(MPL). Is MPL friendly to commercial use? I found a different thread in stackoverflow, one of the comments mentions: MPL: people can take your c...