Skip to content
Snippets Groups Projects
Commit c227dd78 authored by Piotr Maślanka's avatar Piotr Maślanka
Browse files

fix, v0.90

parent bfaa56d7
No related branches found
Tags v0.90
No related merge requests found
......@@ -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)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment