From 50afae24453bced205bca7a50dac2ea92323de9b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Piotr=20Ma=C5=9Blanka?= <piotr.maslanka@henrietta.com.pl>
Date: Tue, 23 Jun 2020 23:17:14 +0200
Subject: [PATCH] 1.2.2 bugfix release
---
CHANGELOG.md | 2 +-
coolamqp/__init__.py | 2 +-
coolamqp/attaches/consumer.py | 17 +++++++++--------
3 files changed, 11 insertions(+), 10 deletions(-)
diff --git a/CHANGELOG.md b/CHANGELOG.md
index dcbdac9..406e329 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,6 +1,6 @@
# v1.2.2
-* _TBA_
+* bugfix release: don't bind if queue is topic
# v1.2.1
diff --git a/coolamqp/__init__.py b/coolamqp/__init__.py
index 6840c94..923b987 100644
--- a/coolamqp/__init__.py
+++ b/coolamqp/__init__.py
@@ -1 +1 @@
-__version__ = '1.2.2_a1'
+__version__ = '1.2.2'
diff --git a/coolamqp/attaches/consumer.py b/coolamqp/attaches/consumer.py
index 96e8387..dc48e07 100644
--- a/coolamqp/attaches/consumer.py
+++ b/coolamqp/attaches/consumer.py
@@ -408,14 +408,15 @@ class Consumer(Channeler):
# We need any form of binding.
if self.queue.exchange is not None:
- self.method_and_watch(
- QueueBind(
- self.queue.name,
- self.queue.exchange.name.encode('utf8'),
- b'', False, []),
- QueueBindOk,
- self.on_setup
- )
+ if self.queue.exchange.type != 'topic':
+ self.method_and_watch(
+ QueueBind(
+ self.queue.name,
+ self.queue.exchange.name.encode('utf8'),
+ b'', False, []),
+ QueueBindOk,
+ self.on_setup
+ )
else:
# default exchange, pretend it was bind ok
self.on_setup(QueueBindOk())
--
GitLab