diff options
| -rw-r--r-- | oslo_messaging/_drivers/amqp.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/oslo_messaging/_drivers/amqp.py b/oslo_messaging/_drivers/amqp.py index 7fd3d37..4a4e3c1 100644 --- a/oslo_messaging/_drivers/amqp.py +++ b/oslo_messaging/_drivers/amqp.py @@ -153,7 +153,8 @@ class ConnectionContext(rpc_common.Connection): self.connection.close() except Exception: pass - else: + self.connection = self.connection_pool.create() + finally: self.connection_pool.put(self.connection) else: try: |