diff --git a/CHANGELOG.md b/CHANGELOG.md index 927d3e76ff8fa2913bfc68aff0ad9d7d5d9e7355..55eef87bc329b12afb89fb3cfb17cacd5fb66baa 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 b42870986d500297da165634832858772a974c5e..af391e6b955eae832cbf4c7dc12b31a7f7d22640 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 24214acfe51bc0000fed291d9437cf5d2d50a262..a18e089f5a6294304aa2f28bae3b9a8744807ebb 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