summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorHervé Beraud <hberaud@redhat.com>2020-11-24 14:49:39 +0100
committerStephen Finucane <stephenfin@redhat.com>2020-12-11 15:31:42 +0000
commit0e4ec379c0bb44bd2b1dc25a2602ae9a944b8c4d (patch)
tree6fc9eafa58fc71fd3eb8da8617e92dafc4e19fd7
parent54f8724be281b1acfae175d7ec1c14e439269117 (diff)
downloadoslo-messaging-0e4ec379c0bb44bd2b1dc25a2602ae9a944b8c4d.tar.gz
fix variable name
Change-Id: I6039d09533c86d651b5c63b500058aac3c9f0a7f
-rw-r--r--oslo_messaging/_drivers/impl_rabbit.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/oslo_messaging/_drivers/impl_rabbit.py b/oslo_messaging/_drivers/impl_rabbit.py
index f436cbe..10f0c2d 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)