From 54f0c9b35eb47a3a3f86f78da399f6674ee37e20 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Piotr=20Ma=C5=9Blanka?= <piotr.maslanka@henrietta.com.pl>
Date: Sat, 24 Dec 2016 05:40:22 +0100
Subject: [PATCH] v0.10
fixes #5 even more
---
coolamqp/backends/pyamqp.py | 2 ++
1 file changed, 2 insertions(+)
diff --git a/coolamqp/backends/pyamqp.py b/coolamqp/backends/pyamqp.py
index 98c9624..0b1deb6 100644
--- a/coolamqp/backends/pyamqp.py
+++ b/coolamqp/backends/pyamqp.py
@@ -42,6 +42,7 @@ class PyAMQPBackend(AMQPBackend):
except AttributeError:
pass # this does not always have to exist
self.channel = self.connection.channel()
+ self.channel.auto_decode = False
self.heartbeat = node.heartbeat or 0
self.last_heartbeat_at = monotonic.monotonic()
@@ -142,6 +143,7 @@ class PyAMQPBackend(AMQPBackend):
self.cluster_handler_thread._on_consumercancelled(consumer_tag)
def __on_message(self, message):
+ assert isinstance(message.body, six.binary_type)
self.cluster_handler_thread._on_recvmessage(six.binary_type(message.body),
message.delivery_info['exchange'],
message.delivery_info['routing_key'],
--
GitLab