diff options
| author | Zuul <zuul@review.opendev.org> | 2021-01-08 14:15:12 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2021-01-08 14:15:12 +0000 |
| commit | 2bc8b9d904750217d6400f401ee3bcb1bb509b29 (patch) | |
| tree | 3a27f4a06fe13c67881ec31ce30be98464619853 | |
| parent | e97ad18706ddf009b3de884b13d8cffdf58d5686 (diff) | |
| parent | 0e4ec379c0bb44bd2b1dc25a2602ae9a944b8c4d (diff) | |
| download | oslo-messaging-2bc8b9d904750217d6400f401ee3bcb1bb509b29.tar.gz | |
Merge "fix variable name"12.6.1
| -rw-r--r-- | oslo_messaging/_drivers/impl_rabbit.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/oslo_messaging/_drivers/impl_rabbit.py b/oslo_messaging/_drivers/impl_rabbit.py index 756641b..ec5cda9 100644 --- a/oslo_messaging/_drivers/impl_rabbit.py +++ b/oslo_messaging/_drivers/impl_rabbit.py @@ -1261,11 +1261,11 @@ class Connection(object): _set_current_channel is responsible to cleanup the cache. """ - queue_indentifier = (exchange.name, routing_key) + queue_identifier = (exchange.name, routing_key) # NOTE(sileht): We only do it once per reconnection # the Connection._set_current_channel() is responsible to clear # this cache - if queue_indentifier not in self._declared_queues: + if queue_identifier not in self._declared_queues: queue = kombu.entity.Queue( channel=self.channel, exchange=exchange, @@ -1279,7 +1279,7 @@ class Connection(object): 'Connection._publish_and_creates_default_queue: ' 'declare queue %(key)s on %(exchange)s exchange', log_info) queue.declare() - self._declared_queues.add(queue_indentifier) + self._declared_queues.add(queue_identifier) self._publish(exchange, msg, routing_key=routing_key, timeout=timeout) |