From b8f67d2870340fa6d0fa81187cf85110a52bb9d9 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Piotr=20Ma=C5=9Blanka?= <piotr.maslanka@henrietta.com.pl>
Date: Thu, 9 Jul 2020 18:53:55 +0200
Subject: [PATCH] v1.2.7
---
CHANGELOG.md | 2 +-
coolamqp/__init__.py | 2 +-
coolamqp/attaches/consumer.py | 4 ++--
3 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 927d3e7..55eef87 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -4,4 +4,4 @@ have been made so far, between releases.
# v1.2.7
-
+* fixed queue being defined as a different one in consumer if it was anonymous
diff --git a/coolamqp/__init__.py b/coolamqp/__init__.py
index b428709..af391e6 100644
--- a/coolamqp/__init__.py
+++ b/coolamqp/__init__.py
@@ -1 +1 @@
-__version__ = '1.2.7_a1'
+__version__ = '1.2.7'
diff --git a/coolamqp/attaches/consumer.py b/coolamqp/attaches/consumer.py
index 24214ac..a18e089 100644
--- a/coolamqp/attaches/consumer.py
+++ b/coolamqp/attaches/consumer.py
@@ -384,7 +384,7 @@ class Consumer(Channeler):
elif isinstance(payload, ExchangeDeclareOk):
# Declare the queue
- name = b'' if self.queue.anonymous else self.queue.name
+ name = self.queue.name
self.connection.method_and_watch(
self.channel_id,
@@ -403,7 +403,7 @@ class Consumer(Channeler):
elif isinstance(payload, QueueDeclareOk):
# did we need an anonymous name?
- if self.queue.anonymous:
+ if not self.queue.name:
self.queue.name = payload.queue.tobytes()
queue_declared = False
--
GitLab