diff options
| author | Kenneth Giusti <kgiusti@gmail.com> | 2018-08-20 12:31:16 -0400 |
|---|---|---|
| committer | Kenneth Giusti <kgiusti@gmail.com> | 2018-08-27 14:42:19 -0400 |
| commit | d03b85e9d63702bbf0c416603f2f705e772dc7da (patch) | |
| tree | b4539d2627d92fc43e34f26c9f36af941b7b7714 | |
| parent | 03e4591fb3e878bdb33a3f8fe59027ac036bc9ad (diff) | |
| download | oslo-messaging-d03b85e9d63702bbf0c416603f2f705e772dc7da.tar.gz | |
Change-Id: I15c8c4a1177c363283281d2fed63545658eda5de
Closes-Bug: #1787214
(cherry picked from commit d9866029a2aab2c5f001100813c0425b4905fdf6)
| -rw-r--r-- | oslo_messaging/_drivers/impl_rabbit.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/oslo_messaging/_drivers/impl_rabbit.py b/oslo_messaging/_drivers/impl_rabbit.py index 59ecf7d..d3c85fb 100644 --- a/oslo_messaging/_drivers/impl_rabbit.py +++ b/oslo_messaging/_drivers/impl_rabbit.py @@ -1160,7 +1160,9 @@ class Connection(object): self.ensure(method, retry=retry, error_callback=_error_callback) def _get_connection_info(self): - info = self.connection.info() + ci = self.connection.info() + info = dict([(k, ci.get(k)) for k in + ['hostname', 'port', 'transport']]) client_port = None if (self.channel and hasattr(self.channel.connection, 'sock') and self.channel.connection.sock): |