fix ajax console proxy for new create_consumer method

This commit is contained in:
Chris Behrens 2011-08-29 15:15:58 -07:00
parent f4d58a968b
commit 38b42096e9

View File

@ -114,8 +114,7 @@ class AjaxConsoleProxy(object):
{'args': kwargs, 'last_activity': time.time()}
self.conn = rpc.create_connection(new=True)
rpc.create_consumer(
self.conn,
self.conn.create_consumer(
FLAGS.ajax_console_proxy_topic,
TopicProxy)