handle non-ascii headers

Author: davidszotten

Modules/_librabbitmq/connection.c

@@ -320,7 +320,7 @@ PyDict_ToAMQTable(amqp_connection_state_t conn, PyObject *src, amqp_pool_t *pool
             is_unicode = PyUnicode_Check(dvalue);
             if (is_unicode || PyBytes_Check(dvalue)) {
                 if (is_unicode) {
-                    if ((dvalue = PyUnicode_AsASCIIString(dvalue)) == NULL)
+                    if ((dvalue = PyUnicode_AsEncodedString(dvalue, "utf-8", "strict")) == NULL)
                         goto error;
                 }
                 AMQTable_SetStringValue(&dst,

tests/test_functional.py

@@ -1,3 +1,4 @@
+# coding: utf-8
 from __future__ import absolute_import
 
 from six.moves import xrange
@@ -30,6 +31,14 @@ def test_send_message(self):
         self.assertGreater(self.channel.queue_purge(TEST_QUEUE), 2)
         self.channel.basic_publish(message, TEST_QUEUE, TEST_QUEUE)
         self.channel.basic_publish(message, TEST_QUEUE, TEST_QUEUE)
+
+    def test_nonascii_headers(self):
+        message = Message(
+            channel=self.channel,
+            body='the quick brown fox jumps over the lazy dog',
+            properties=dict(content_type='application/json',
+                            content_encoding='utf-8',
+                            headers={'key': '¯\_(ツ)_/¯'}))
         self.channel.basic_publish(message, TEST_QUEUE, TEST_QUEUE)
 
     def _queue_declare(self):