handle single-element routing key as tuple, list
This commit is contained in:
@@ -243,6 +243,9 @@ class Statement(object):
|
|||||||
|
|
||||||
def _set_routing_key(self, key):
|
def _set_routing_key(self, key):
|
||||||
if isinstance(key, (list, tuple)):
|
if isinstance(key, (list, tuple)):
|
||||||
|
if len(key) == 1:
|
||||||
|
self._routing_key = key[0]
|
||||||
|
else:
|
||||||
self._routing_key = b"".join(self._key_parts_packed(key))
|
self._routing_key = b"".join(self._key_parts_packed(key))
|
||||||
else:
|
else:
|
||||||
self._routing_key = key
|
self._routing_key = key
|
||||||
|
|||||||
Reference in New Issue
Block a user