amqp

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...

Does the content type header in RabbitMQ have any special meaning?

Does the content type header in RabbitMQ have any special meaning, or is it only a standardized way for my producers and consumers to signal what kind of data they are sending? In other words: will messages with certain content types get any special treatment, or is it just bytes, either way? ...

Content-based routing with RabbitMQ and Python

Is it possible with RabbitMQ and Python to do content-based routing? The AMQP standard and RabbitMQ claims to support content-based routing, but are there any libraries for Python which support specifying content-based bindings etc.? The library I am currently using (py-amqplib http://barryp.org/software/py-amqplib/) seems to only supp...

RabbitMQ message consumers stop consuming messages

Hi stackoverflowers, Our team is in a spike sprint to choose between ActiveMQ or RabbitMQ. We made 2 little producer/consumer spikes sending an object message with an array of 16 strings, a timestamp, and 2 integers. The spikes are ok on our devs machines (messages are well consumed). Then came the benchs. We first noticed that somtime...

RabbitMQ/AMQP unhandled channel error - NOT_FOUND

I'm trying to publish messages to RabbitMQ, from a Ruby script (using Bunny) and consume them from a node.js server (using node-amqp). The first message arrives successfully, but then an error is logged inside node.js, and the connection closes, and no further messages are received: mu:charlie-node tom$ node charlie.js 22 Jul 09:11:04...

Pre-built AMQP and STOMP client (as in GUI client)

Hi, I'm looking for a client (as in GUI client, not client library) to play with our MQ server and familiarize myself with its semantics. Something that will send and receive messages at the press of a button (or a text command) and maybe even update me about the status of the server queues and messages. Administration would be a bonus....

AMQP + Android libraries

Is any amqp libraries for Android? ...

How to make RabbitMQ queues failover?

RabbitMQ supports clustering by default, but queues aren't replicated and are bound to the node on which they're created. I'm now looking for ways to make RabbitMQ highly available other than the DRBD solution that they've documented, because it seems like a waste of resources to reserve an entire server that's doing nothing but waiting ...

Simple protocols (like twisted.pb) vs messaging (AMQP/JMS) vs web services (REST/SOAP)

Hi, I'm currently using twisted's perspective broker on python and I have considered in the past switching to something like RabbitMQ but I'm not sure it could just replace pb - I feel like I might be comparing apples to oranges here. I've been reading a lot about REST lately and the inevitable debate with SOAP, which led me to read abou...

How to selectively delete messages from an AMQP (RabbitMQ) queue?

I'd like to selectively delete messages from an AMQP queue without even reading them. The scenario is as follows: Sending side wants to expire messages of type X based on a fact that new information of type X arrived. Because it's very probable that the subscriber didn't consume latest message of type X yet, publisher should just delet...

Is message priority inherently unimportant in message queue systems?

It seems like most of the messaging systems I've looked at have basic, if any, support for priority message queues. For example, the AMQP only specifies a minimum of 2 priorities. RabbitMQ, an AMQP implementation, doesn't support any priorities. ActiveMQ will be getting support for 10 message priorities in version 5.4 in a couple days. 1...

Producer work consistently hashing to consumers via a message queue?

I have a producer that I want to distribute work consistently across consumers by consistent hashing. For example, with consumer nodes X and Y, tasks A, B, C should always go to consumer X, and D, E, F to consumer Y. But that may shift a little if Z joins the pool of consumers. I didn't want to deal with writing my own logic to connect ...

Implementing message priority in AMQP

Hello all, I'm intending to use AMQP to allow a distributed collection of machines to report to a central location asynchronously. The idea is to drop messages into the queue and allow the central logging entity to process the queue in a decoupled fashion; the 'process' is simply to create or update a row in a database table. A proble...

Unable to install AMQP for PHP - Symbol not found error

I'm getting the following error when running the code listed below. I have install AMQP extension through PECL and it shows up fine in my php.ini file when I do phpinfo both from the command line and browser. <?php // amqp rabbitmq client test // Create a connection $cnn = new AMQPConnection(); exit(); ?> When tr...

How do you compile a PHP extension on windows with cygwin/mingw?

I am trying to build the RabbitMQ PHP wrapper and the AMPQ PHP wrapper on Windows (64) using Cygwin. I have successfully built the underlying C library (librabbitmq.dll) but I am stuck at the 'phpize' step: phpize && ./configure --with-rabbit && make && sudo make install If I understand correctly, there is no 'phpize' on windows, so ho...

workling client stops in a few seconds after start

Hi I'm trying to use RabbitMQ instead of Starling I've configured my app and everything seems to be fine but when i run 'script/ workling_client start' it starts to work and ends in a few seconds and I can't get why My app works perfectly with Starling I'm using Fedora 13 ruby 1.8.7 rails 2.3.8 mongrel(configured according to http://gi...

Has anyone compiled a rabbitmq/amqp library for php 5.2.x on windows x64

I'm trying to publish messages to RabbitMQ from a php (5.2.x) script on my windows X64 dev machine. The problem is that I didn't find any dll extension for php. My collegue is actually trying to build it (cf. How do you compile a PHP extension on windows with cygwin/mingw?), but without success :(. Does anyone know where I can find a v...

Looking for a book on queue-based applications

I'm looking for a good book on building messaging and queue based applications. Good practices, design patterns etc. for things like twitter feeds, publish and subscribe feeds, AMQP, rabbitMQ etc. ...

How to retract a message in RabbitMQ?

I've got something like a job queue over RabbitMQ and, upon a request to cancel a job, I'd like to retract the tasks that have not yet started processing (their messages have not been ack'd), which corresponds to retracting these messages from the queues that they've been routed to. I haven't found this functionality in AMQP or in the R...

AMQP/RabbitMQ or Node.js for live web applications?

I want to build a live application that supports server-push (chat, feeds, live notification and collaboration etc). I have looked into Node.js and found it quite interesting and appropriate for such things. I have also looked into AMQP/RabbitMQ, but I don't get these quite. My questions: How does AMQP/RabbitMQ compare to Node.js? C...