fix variable name
Change-Id: I6039d09533c86d651b5c63b500058aac3c9f0a7f
This commit is contained in:
parent
54f8724be2
commit
0e4ec379c0
|
@ -1261,11 +1261,11 @@ class Connection(object):
|
||||||
|
|
||||||
_set_current_channel is responsible to cleanup the cache.
|
_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
|
# NOTE(sileht): We only do it once per reconnection
|
||||||
# the Connection._set_current_channel() is responsible to clear
|
# the Connection._set_current_channel() is responsible to clear
|
||||||
# this cache
|
# this cache
|
||||||
if queue_indentifier not in self._declared_queues:
|
if queue_identifier not in self._declared_queues:
|
||||||
queue = kombu.entity.Queue(
|
queue = kombu.entity.Queue(
|
||||||
channel=self.channel,
|
channel=self.channel,
|
||||||
exchange=exchange,
|
exchange=exchange,
|
||||||
|
@ -1279,7 +1279,7 @@ class Connection(object):
|
||||||
'Connection._publish_and_creates_default_queue: '
|
'Connection._publish_and_creates_default_queue: '
|
||||||
'declare queue %(key)s on %(exchange)s exchange', log_info)
|
'declare queue %(key)s on %(exchange)s exchange', log_info)
|
||||||
queue.declare()
|
queue.declare()
|
||||||
self._declared_queues.add(queue_indentifier)
|
self._declared_queues.add(queue_identifier)
|
||||||
|
|
||||||
self._publish(exchange, msg, routing_key=routing_key, timeout=timeout)
|
self._publish(exchange, msg, routing_key=routing_key, timeout=timeout)
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue