From c227dd789f842da0dafbb42d4284f8b0551d5376 Mon Sep 17 00:00:00 2001 From: Piotr Maslanka <piotr.maslanka@henrietta.com.pl> Date: Sun, 5 Feb 2017 06:47:58 +0100 Subject: [PATCH] fix, v0.90 --- coolamqp/objects.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/coolamqp/objects.py b/coolamqp/objects.py index e609700..c7fd455 100644 --- a/coolamqp/objects.py +++ b/coolamqp/objects.py @@ -179,9 +179,9 @@ class Queue(object): self.auto_delete = auto_delete self.exclusive = exclusive - self.anonymous = len(name) == 0 # if this queue is anonymous, it must be regenerated upon reconnect + self.anonymous = len(self.name) == 0 # if this queue is anonymous, it must be regenerated upon reconnect - self.consumer_tag = name if not self.anonymous else uuid.uuid4().hex.encode('utf8') # bytes, consumer tag to use in AMQP comms + self.consumer_tag = self.name if not self.anonymous else uuid.uuid4().hex.encode('utf8') # bytes, consumer tag to use in AMQP comms assert isinstance(self.name, six.binary_type) assert isinstance(self.consumer_tag, six.binary_type) -- GitLab