From c8222227193f91bcbc4d438d0c781fd62ab441b4 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Piotr=20Ma=C5=9Blanka?= <piotr.maslanka@henrietta.com.pl>
Date: Thu, 25 Jun 2020 14:34:03 +0200
Subject: [PATCH] 1.2.4
---
CHANGELOG.md | 2 +-
coolamqp/__init__.py | 2 +-
coolamqp/attaches/consumer.py | 5 ++++-
3 files changed, 6 insertions(+), 3 deletions(-)
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 21e3b24..f684112 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,6 +1,6 @@
# v1.2.4
-* _TBA_
+* bugfix release
# v1.2.3
diff --git a/coolamqp/__init__.py b/coolamqp/__init__.py
index afa761a..daab838 100644
--- a/coolamqp/__init__.py
+++ b/coolamqp/__init__.py
@@ -1 +1 @@
-__version__ = '1.2.4_a1'
+__version__ = '1.2.4'
diff --git a/coolamqp/attaches/consumer.py b/coolamqp/attaches/consumer.py
index 8b93230..24214ac 100644
--- a/coolamqp/attaches/consumer.py
+++ b/coolamqp/attaches/consumer.py
@@ -406,9 +406,11 @@ class Consumer(Channeler):
if self.queue.anonymous:
self.queue.name = payload.queue.tobytes()
+ queue_declared = False
# We need any form of binding.
if self.queue.exchange is not None:
if self.queue.exchange.type != b'topic':
+ queue_declared = True
self.method_and_watch(
QueueBind(
self.queue.name,
@@ -417,7 +419,8 @@ class Consumer(Channeler):
QueueBindOk,
self.on_setup
)
- else:
+
+ if not queue_declared:
# default exchange, pretend it was bind ok
self.on_setup(QueueBindOk())
elif isinstance(payload, QueueBindOk):
--
GitLab