diff options
| author | Chris Behrens <cbehrens@codestud.com> | 2011-08-30 20:53:27 -0700 |
|---|---|---|
| committer | Chris Behrens <cbehrens@codestud.com> | 2011-08-30 20:53:27 -0700 |
| commit | b7c98734f8829fb4b213869bdfca6481fbeab98e (patch) | |
| tree | f400fc984c261063d3868977df4020fefa2b85db | |
| parent | 2e12e975ee9d4ab7a17eebb0e36714b56d6b1779 (diff) | |
use kombu.connection.BrokerConnection vs kombu.connection.Connection so that older versions of kombu (1.0.4) work as well as newer.
| -rw-r--r-- | nova/rpc/impl_kombu.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/nova/rpc/impl_kombu.py b/nova/rpc/impl_kombu.py index 8242bd177..ab70e7cfb 100644 --- a/nova/rpc/impl_kombu.py +++ b/nova/rpc/impl_kombu.py @@ -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 |