x/python-ganttclient
Code Issues Proposed changes

use kombu.connection.BrokerConnection vs kombu.connection.Connection so that older versions of kombu (1.0.4) work as well as newer.

Browse Source
This commit is contained in:
Chris Behrens
2011-08-30 20:53:27 -07:00
parent d441093814
commit 49716b9e0f
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
nova/rpc/impl_kombu.py
View File

@@ -322,7 +322,7 @@ class Connection(object):
except self.connection.connection_errors:
pass
time.sleep(1)
self.connection = kombu.connection.Connection(**self.params)
self.connection = kombu.connection.BrokerConnection(**self.params)
if FLAGS.fake_rabbit:
# Kludge to speed up tests.
self.connection.transport.polling_interval = 0.0