diff options
| author | Hengqing Hu <hudayou@hotmail.com> | 2012-12-28 18:33:46 +0800 |
|---|---|---|
| committer | Hengqing Hu <hudayou@hotmail.com> | 2012-12-28 18:33:46 +0800 |
| commit | 90606f8cb286ff252046eef15396b81e7ba37195 (patch) | |
| tree | 53243ad692a30d365c384481289fd3ba1cdf7084 /openstack/common | |
| parent | 8888ad0126f25c91b90f7bc4c2440da0bf35ec1d (diff) | |
| download | oslo-90606f8cb286ff252046eef15396b81e7ba37195.tar.gz oslo-90606f8cb286ff252046eef15396b81e7ba37195.tar.xz oslo-90606f8cb286ff252046eef15396b81e7ba37195.zip | |
Close kombu.connection.BrokerConnection correctly
Make kombu.connection.BrokerConnection use release() to close the connection.
It has no such attribute as close(), since AttributeError is in
connection_errors, the fault was previous concealed by the following catch
statement.
Change-Id: I9f7da2c64f9d408aa2a9ddf723ea83291887cff6
Diffstat (limited to 'openstack/common')
| -rw-r--r-- | openstack/common/rpc/impl_kombu.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/openstack/common/rpc/impl_kombu.py b/openstack/common/rpc/impl_kombu.py index ced4e96..5bc7a6a 100644 --- a/openstack/common/rpc/impl_kombu.py +++ b/openstack/common/rpc/impl_kombu.py @@ -469,7 +469,7 @@ class Connection(object): LOG.info(_("Reconnecting to AMQP server on " "%(hostname)s:%(port)d") % params) try: - self.connection.close() + self.connection.release() except self.connection_errors: pass # Setting this in case the next statement fails, though |