<br><br><div class="gmail_quote">On Tue, Nov 13, 2012 at 6:22 PM, Ray Pekowski <span dir="ltr"><<a href="mailto:pekowski@gmail.com" target="_blank">pekowski@gmail.com</a>></span> wrote:<br><blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">
<div class="gmail_quote"><div class="im">On Tue, Nov 13, 2012 at 1:06 PM, Russell Bryant <span dir="ltr"><<a href="mailto:rbryant@redhat.com" target="_blank">rbryant@redhat.com</a>></span> wrote:<br><blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">

<div>On 11/13/2012 01:24 PM, Vishvananda Ishaya wrote:<br>
><br>
> On Nov 13, 2012, at 10:14 AM, Ray Pekowski <<a href="mailto:pekowski@gmail.com" target="_blank">pekowski@gmail.com</a><br>
</div><div>> <mailto:<a href="mailto:pekowski@gmail.com" target="_blank">pekowski@gmail.com</a>>> wrote:<br>
>><br>
>> My question is whether anyone thinks it is a worthwhile effort to<br>
>> investigate code changes to the Openstack RPC that would make the RPC<br>
>> responses flow on static exchanges and queues?<br>
>><br>
><br>
> Yes I think this is worthwhile. A few people have tried this out and<br>
> there doesn't seem to be any reason why this wouldn't work. This should<br>
> be done in oslo-incubator (formerly openstack-common)<br>
<br>
</div>The dynamic creation is of *queues*, right?  Not of exchanges and queues<br>
as specified before?  It only seems valuable to have dynamic queues for<br>
responses, which I'm pretty sure is how it works.<br></blockquote></div><div><br>I don't know for sure if exchanges are being created or not, but here is the output from a kombu log an RPC and you will see an exchange_declare on the cleint and server side for e8e85bf237944223994eecd283a582da.<br>

<br></div></div></blockquote><div><br>Oops, copy paste didn't work for those first logs.  Here are the right ones:<br><br>RPC Client:<br><br>[Kombu connection:0x2fbce10] establishing connection...<br>[Kombu connection:0x2fbce10] connection established: <kombu.transport.pyamqplib.Connection object at 0x318a290><br>
[Kombu connection:0x2fbce10] create channel<br>[Kombu channel:1] exchange_declare(nowait=False, exchange='e8e85bf237944223994eecd283a582da', durable=False, arguments=None, type='direct', auto_delete=True)<br>
[Kombu channel:1] queue_declare(exclusive=True, nowait=False, durable=False, queue='e8e85bf237944223994eecd283a582da', arguments=None, passive=False, auto_delete=True)<br>[Kombu channel:1] queue_bind(queue='e8e85bf237944223994eecd283a582da', exchange='e8e85bf237944223994eecd283a582da', nowait=False, routing_key='e8e85bf237944223994eecd283a582da', arguments=None)<br>
[Kombu channel:1] exchange_declare(nowait=False, exchange='nova', durable=False, arguments=None, type='topic', auto_delete=False)<br>[Kombu channel:1] prepare_message('{"_context_roles": [], "_msg_id": "e8e85bf237944223994eecd283a582da", "_context_quota_class": null, "_context_request_id": "req-889602cb-60dc-42f5-b7fd-107412e059c7", "_context_service_catalog": null, "args": {"req_args": <MY DATA DELETED FOR SPACE>}, "_context_auth_token": null, "_context_user_id": null, "_context_project_name": null, "_context_read_deleted": "no", "_context_instance_lock_checked": false, "_context_is_admin": true, "version": "2.0", "_context_project_id": null, "_context_timestamp": "2012-11-13T23:53:24.985241", "_context_user_name": null, "method": "nested_call_request", "_context_remote_address": null}', priority=0, headers={}, properties={'delivery_mode': 2}, content_type='application/json', content_encoding='utf-8')<br>
[Kombu channel:1] basic_publish(<amqplib.client_0_8.basic_message.Message object at 0x31bc390>, mandatory=False, routing_key='perfsvc4', immediate=False, exchange='nova')<br>[Kombu channel:1] basic_consume(queue='e8e85bf237944223994eecd283a582da', consumer_tag='1', nowait=False, no_ack=False, callback=<function _callback at 0x31bbf50>)<br>
[Kombu channel:1] message_to_python(<amqplib.client_0_8.basic_message.Message object at 0x31bc210>)<br>[Kombu channel:1] message_to_python(<amqplib.client_0_8.basic_message.Message object at 0x31bc390>)<br>[Kombu channel:1] close()<br>
[Kombu connection:0x2fbce10] create channel<br><br>RPC Server<br><br>[Kombu channel:1] message_to_python(<amqplib.client_0_8.basic_message.Message object at 0x4be99d0>)<br>[Kombu connection:0x4a37d50] establishing connection...<br>
[Kombu connection:0x4a37d50] connection established: <kombu.transport.pyamqplib.Connection object at 0x4be1c10><br>[Kombu connection:0x4a37d50] create channel<br>[Kombu channel:1] exchange_declare(nowait=False, exchange=u'e8e85bf237944223994eecd283a582da', durable=False, arguments=None, type='direct', auto_delete=True)<br>
[Kombu channel:1] prepare_message('{"failure": null, "result": <MY DATA DELETED FOR SPACE>}', priority=0, headers={}, properties={'delivery_mode': 2}, content_type='application/json', content_encoding='utf-8')<br>
[Kombu channel:1] basic_publish(<amqplib.client_0_8.basic_message.Message object at 0x4cb1550>, mandatory=False, routing_key=u'e8e85bf237944223994eecd283a582da', immediate=False, exchange=u'e8e85bf237944223994eecd283a582da')<br>
[Kombu channel:1] close()<br>[Kombu connection:0x4a37d50] create channel<br>[Kombu channel:1] exchange_declare(nowait=False, exchange=u'e8e85bf237944223994eecd283a582da', durable=False, arguments=None, type='direct', auto_delete=True)<br>
[Kombu channel:1] prepare_message('{"failure": null, "result": null, "ending": true}', priority=0, headers={}, properties={'delivery_mode': 2}, content_type='application/json', content_encoding='utf-8')<br>
[Kombu channel:1] basic_publish(<amqplib.client_0_8.basic_message.Message object at 0x4cb1e90>, mandatory=False, routing_key=u'e8e85bf237944223994eecd283a582da', immediate=False, exchange=u'e8e85bf237944223994eecd283a582da')<br>
[Kombu channel:1] close()<br>[Kombu connection:0x4a37d50] create channel<br><br>Ray<br><br><br><br><br> </div></div>