amqp

Is AMQP suitable as both an intra and inter-machine software bus?

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

Serializing objects for asynchronous messaging

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

Deliver multicast to several different geo-locations

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

Which group messaging technology to use?

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

RabbitMQ C# client not talking to Apache Qpid Java Broker

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

Does JBoss Messaging support non-Java clients?

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

What's the best option for a framework-agnostic Ruby background worker library?

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

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

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

How would you encode a Map<String, Object> using Protocol Buffers?

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

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

AMQP Delay Delivery and Prevent Duplicate Messages

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

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

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

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

Can I use the Advanced Message Queuing Protocol (AMQP)?

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

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

How to do Distributed Calculations in Excel

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