puka doesn't work with unicode strings in message header

Change-Id: I671db60b2b8877dfc38cfd82b040e5a760c2e168
This commit is contained in:
Stan Lagun 2013-10-31 13:37:41 +04:00
parent d2ffd0ba74
commit dc0906ca1d

View File

@ -78,7 +78,7 @@ class MqClient(object):
if not self._connected: if not self._connected:
raise RuntimeError('Not connected to RabbitMQ') raise RuntimeError('Not connected to RabbitMQ')
headers = {'message_id': message.id} headers = {'message_id': str(message.id)}
promise = self._client.basic_publish( promise = self._client.basic_publish(
exchange=str(exchange), exchange=str(exchange),