diff options
| author | Jenkins <jenkins@review.openstack.org> | 2013-01-07 20:00:31 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2013-01-07 20:00:31 +0000 |
| commit | 1e50543ca215fc5d160f8b740115835e291c7dde (patch) | |
| tree | 647aa3a42777a0138cc70d29121e19a3d97669e3 /openstack/common/rpc/impl_kombu.py | |
| parent | d40cf1d04230947301e88a57d8ac97e74de7bbe6 (diff) | |
| parent | 90606f8cb286ff252046eef15396b81e7ba37195 (diff) | |
| download | oslo-1e50543ca215fc5d160f8b740115835e291c7dde.tar.gz oslo-1e50543ca215fc5d160f8b740115835e291c7dde.tar.xz oslo-1e50543ca215fc5d160f8b740115835e291c7dde.zip | |
Merge "Close kombu.connection.BrokerConnection correctly"
Diffstat (limited to 'openstack/common/rpc/impl_kombu.py')
| -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 8129e15..19f0348 100644 --- a/openstack/common/rpc/impl_kombu.py +++ b/openstack/common/rpc/impl_kombu.py @@ -471,7 +471,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 |