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 db27d93bc1
commit 468ed47520
1 changed files with 1 additions and 2 deletions

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)