From 7152705d364590298675e0ee84e6d9a67bf1ee14 Mon Sep 17 00:00:00 2001 From: Robert Kopaczewski Date: Thu, 27 Apr 2017 09:46:04 +0200 Subject: [PATCH] Fix librabbitmq queue handling (#726) --- AUTHORS | 1 + kombu/transport/librabbitmq.py | 3 ++- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/AUTHORS b/AUTHORS index 7d810da5..b5f30aa9 100644 --- a/AUTHORS +++ b/AUTHORS @@ -109,6 +109,7 @@ Ralf Nyren Randy Barlow Raphael Michel Rob Ottaway +Robert Kopaczewski Roger Hu Rumyana Neykova Rune Halvorsen diff --git a/kombu/transport/librabbitmq.py b/kombu/transport/librabbitmq.py index d5ed2b9c..8d91e474 100644 --- a/kombu/transport/librabbitmq.py +++ b/kombu/transport/librabbitmq.py @@ -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):