I'm trying to get my head around AMQP. It looks great for inter-machine (cluster, LAN, WAN) communication between applications but I'm not sure if it is suitable (in architectural, and current implementation terms) for use as a software bus within one machine. Would it be worth pulling out a current high performance message passing fram...
I'm considering using AMQP (using qpid) to enable a mixture of Python and Java services communicate with each other. Basic text messaging seems simple enough but, as with every other messaging technology I've investigated, that's where it seems to stop. Except for building instant messaging applications, I would have thought sending stri...
I need to use one logical PGM based multicast address in application while enable such application "seamlessly" running across several different geo-locations (i.e. think US/Europe/Australia). Application is quite throughput (several million biz. messages a day) and latency demanding whith a lot of small but very frequently send message...
I feel a little bit kind of confused — for about 24 hours I have been thinking which group broadcasting technology to use in my project. Basically, what I need is: create groups (by some backend process) broadcast messages by any client (1:N, N:N) (potentially) direct messages (1:1) (important) authenticate/authorize clients with my o...
I've installed the M4 release of the Apache Qpid Java broker on a Windows box, and started it using the out-of-the-box configuration (via the qpid-server.bat script). I'm now trying to publish a message to a queue using the RabbitMQ C# client library (version 1.5.3, compiled for .NET 3.0); my code is: public void PublishMessage(string ...
For enterprise integration projects, a non-Java access to message brokers like JJBoss Messaging can be very helpful. For the Apache ActiveMQ and the GlassFish Open Message Queue products there are many different client implementations available, using native or standard protocols like Stomp. JBoss Messaging has a task "Implement STOMP p...
I'm building a simple recipe search engine with Ruby and Sinatra for an iPhone app, using RabbitMQ for my message queue. I'm looking around and finding a lot of different implementation choices for background processes, but most of them either implement custom message queue algorithms or operate as Rails plugins. What's out there in te...
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. ...
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 ...
I'm trying to use Protocol Buffers for message serialization. My message format should contain Map< String, Object > entries ... but how do I write the .proto definition? As far as I know, Protocol Buffers does not have a build-in Map type. I could model around that using repeating fields. But the big problem I have is, that you need ...
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...
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 ...
I have a system that will generate messages sporadically, and I would like to only submit either zero or one message every 5 minutes. If no message is generated, nothing would be processed by the queue consumer. If a hundred identical messages are generated within 5 minutes I only want one of those to be consumed from the queue. I am ...
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...
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...
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...
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? ...
We develop system with client-server architecture. But in our case client must communicate with server in off-line file mode. Is it correct to use AMQP in this case? ...
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...
A number of years ago I implemented an asynchronous peer-to-peer Message-Oriented-Middle-ware that was very friendly to use in Excel VBA, and I find myself again needing to do lots of calculations which could be trivially distributed, if I had the mechanism. I could re-implement the MOM layer, but I'd prefer to use a third party product...