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

fixes #3

parent 3abdfb2b
No related branches found
No related tags found
No related merge requests found
Pipeline #63413 failed with stages
in 2 minutes and 3 seconds
......@@ -27,6 +27,8 @@ def toutf8(q):
def tobytes(q):
if isinstance(q, memoryview):
return q.tobytes()
return q.encode('utf-8') if isinstance(q, six.text_type) else q
......@@ -287,8 +289,7 @@ class Queue(object):
if name is None:
self.name = None
else:
name = uuid.uuid4().hex if not name else name
self.name = tobytes(name)
self.name = tobytes(uuid.uuid4().hex if not name else name)
self.durable = durable
self.exchange = exchange
......
# coding=UTF-8
from __future__ import print_function, absolute_import, division
import sys
import logging
import unittest
import io
......@@ -26,7 +27,7 @@ class TestObjects(unittest.TestCase):
with warnings.catch_warnings(record=True) as w:
Queue('test', auto_delete=True, exclusive=True)
Queue(auto_delete=True, exclusive=False)
self.assertEqual(len(w), 2)
self.assertEqual(len(w), 2 if sys.version.startswith('3') else 1)
self.assertTrue(issubclass(w[0].category, UserWarning))
self.assertTrue(issubclass(w[1].category, DeprecationWarning))
......
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