1.2.2 bugfix release

CHANGELOG.md

 # v1.2.2
 
-* _TBA_
+* bugfix release: don't bind if queue is topic
 
 # v1.2.1
 

coolamqp/__init__.py

-__version__ = '1.2.2_a1'
+__version__ = '1.2.2'

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())