[rabbitmq-discuss] RabbitMQ scaling with OpenStack

Wed Jan 23 02:04:18 GMT 2013

On Jan 22, 2013, at 1:58 PM, Ask Solem <ask at rabbitmq.com> wrote:

> I could help you review the code as I have lots of experience optimizing
> this pattern and Python consumers.

It would be great if you could review the code.  Here is where the Kombu
interface is implemented in OpenStack

https://github.com/openstack/nova/blob/master/nova/openstack/common/rpc/impl_kombu.py

Roughly, the RPC call is sent by TopicPublisher (caller), then received by
TopicConsumers (callee).  The response is sent by DirectPublisher (callee)
and received by DirectConsumer (caller).  In real time, the consumes happen
before the publishes.

The RPC calls to impl_kombu.py come from amqp.py. which is simply a common
higher level set of methods that either calls methods from impl_kombu.py or
impl_qpid.py depending upon which implementation is configured.

Ray
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130122/b791958b/attachment.htm>