Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix librabbitmq queue handling (#726)

This commit is contained in:
Robert Kopaczewski 2017-04-27 09:46:04 +02:00 committed by Omer Katz
parent d27abc837d
commit 7152705d36
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
AUTHORS
View File

@ -109,6 +109,7 @@ Ralf Nyren <ralf-github@nyren.net>
Randy Barlow <rbarlow@redhat.com>
Raphael Michel <mail@raphaelmichel.de>
Rob Ottaway <robottaway@gmail.com>
Robert Kopaczewski <rk@23doors.com>
Roger Hu <rhu@hearsaycorp.com>
Rumyana Neykova <rumi.neykova@gmail.com>
Rune Halvorsen <runeh@opera.com>

3
kombu/transport/librabbitmq.py
View File

@ -62,7 +62,8 @@ class Channel(amqp.Channel, base.StdChannel):
return body, properties
def prepare_queue_arguments(self, arguments, **kwargs):
return to_rabbitmq_queue_arguments(arguments, **kwargs)
arguments = to_rabbitmq_queue_arguments(arguments, **kwargs)
return {k.encode('utf8'): v for k, v in items(arguments)}
class Connection(amqp.Connection):