From 4166e700d22b89da1bc053290e53848d61a603b2 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Piotr=20Ma=C5=9Blanka?= <piotr.maslanka@henrietta.com.pl>
Date: Wed, 13 Nov 2024 08:45:01 +0100
Subject: [PATCH] fixed #10
---
coolamqp/attaches/consumer.py | 9 ++++-----
tests/test_clustering/test_topic_exchanges.py | 5 +++--
2 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/coolamqp/attaches/consumer.py b/coolamqp/attaches/consumer.py
index f5d6474..2937dc0 100644
--- a/coolamqp/attaches/consumer.py
+++ b/coolamqp/attaches/consumer.py
@@ -396,24 +396,23 @@ class Consumer(Channeler):
elif isinstance(payload, QueueDeclareOk):
# did we need an anonymous name?
if not self.queue.name:
- self.queue.name = self.queue.name.tobytes()
+ self.queue.name = payload.queue.tobytes()
- queue_declared = False
+ queue_bound = False
# We need any form of binding.
if self.queue.exchange is not None:
- queue_declared = True
+ queue_bound = True
qb = QueueBind(
self.queue.name,
self.queue.exchange.name.encode('utf-8'),
self.queue.routing_key, False, self.queue.arguments_bind)
- logger.debug('Running %s' % (repr(qb)))
self.method_and_watch(
qb,
QueueBindOk,
self.on_setup
)
- if not queue_declared:
+ if not queue_bound:
# default exchange, pretend it was bind ok
self.on_setup(QueueBindOk())
elif isinstance(payload, QueueBindOk):
diff --git a/tests/test_clustering/test_topic_exchanges.py b/tests/test_clustering/test_topic_exchanges.py
index b44efe7..0a2bfab 100644
--- a/tests/test_clustering/test_topic_exchanges.py
+++ b/tests/test_clustering/test_topic_exchanges.py
@@ -44,12 +44,13 @@ class TestTopic(unittest.TestCase):
self.c.declare(queue2).result()
test = {'a': 0}
+
def do_message(msg):
msg.ack()
test['a'] += 1
- cons1, fut1 = self.c.consume(queue1, no_ack=False)
- cons2, fut2 = self.c.consume(queue2, no_ack=False)
+ cons1, fut1 = self.c.consume(queue1, on_message=do_message, no_ack=False)
+ cons2, fut2 = self.c.consume(queue2, on_message=do_message, no_ack=False)
fut1.result()
fut2.result()
--
GitLab