diff options
| -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 72eee80..10bb8f1 100644 --- a/oslo_messaging/_drivers/impl_rabbit.py +++ b/oslo_messaging/_drivers/impl_rabbit.py @@ -1155,7 +1155,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): |