openstack/oslo.messaging
Code Issues Proposed changes

Connection pool bugfix

Browse Source 
This is only seen if you try to call amqp.cleanup().

Change-Id: I5c14a21987b4b7aeca7dddc91d7c8b2510edefeb
This commit is contained in:
Mark McLoughlin 2013-07-26 07:41:09 +01:00
parent 29dcc87052
commit 45ab8699a6
1 changed files with 1 additions and 1 deletions

2
oslo/messaging/_drivers/amqp.py

@ -72,7 +72,7 @@ class ConnectionPool(pool.Pool):
return self.connection_cls(self.conf)
def empty(self):
for item in self.iter_free:
for item in self.iter_free():
item.close()
# Force a new connection pool to be created.
# Note that this was added due to failing unit test cases. The issue