On Jan 22, 2013, at 1:58 PM, Ask Solem <ask at <a href="http://rabbitmq.com">rabbitmq.com</a>> wrote:<br><br>> I could help you review the code as I have lots of experience optimizing<br>> this pattern and Python consumers.<br>
<br>It would be great if you could review the code. Here is where the Kombu interface is implemented in OpenStack<br><br><a href="https://github.com/openstack/nova/blob/master/nova/openstack/common/rpc/impl_kombu.py">https://github.com/openstack/nova/blob/master/nova/openstack/common/rpc/impl_kombu.py</a><br>
<br>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.<br>
<br>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.<br>
<br>Ray<br><br>