openstack
/
deb-python-pika-pool
Code Issues Proposed changes

fix cxn str to work w/ pika.BlockingConnection

This commit is contained in:
aisch 2016-05-27 10:09:12 -07:00
parent 701e2f97f4
commit 271f6baa33
2 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
pika_pool.py
View File

@ -231,9 +231,22 @@ class Pool(object):
if not Connection.is_connection_invalidated(ex):
raise
@property
def cxn_params(self):
if isinstance(self.cxn, pika.BaseConnection):
return self.cxn.params
if isinstance(self.cxn, pika.BlockingConnection):
return self.cxn._impl.params
@property
def cxn_str(self):
params = self.cxn_params
if params:
return '{0}:{1}/{2}'.format(params.host, params.port, params.virtual_host)
def __str__(self):
return ', '.join('{0}={1}'.format(k, v) for k, v in [
('cxn', '{0}:{1}/{2}'.format(self.cxn.params.host, self.cxn.params.port, self.cxn.params.virtual_host)),
('cxn', self.cxn_str),
('channel', '{0}'.format(int(self.channel) if self.channel is not None else self.channel)),
])
@ -358,7 +371,7 @@ class QueuedPool(Pool):
def __str__(self):
return ', '.join('{0}={1}'.format(k, v) for k, v in [
('cxn', '{0}:{1}/{2}'.format(self.cxn.params.host, self.cxn.params.port, self.cxn.params.virtual_host)),
('cxn', self.cxn_str),
('channel', '{0}'.format(int(self.channel) if self.channel is not None else self.channel)),
('created_at', '{0}'.format(datetime.fromtimestamp(self.created_at).isoformat())),
('released_at', '{0}'.format(datetime.fromtimestamp(self.released_at).isoformat())),

1
test.py
View File

@ -139,6 +139,7 @@ def test_use_it():
delivery_mode=2,
)
)
assert 'cxn=localhost:5672//' in str(cxn.fairy)
class TestQueuedPool(object):