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

Fix Pika 0.9.5 

Pika doesn't work on Kombu 2.3.2 because we are preparing the message with properties that don't exist. Remove them.
This commit is contained in:
Steeve Morin 2012-08-09 18:56:03 +03:00
parent 597c35789e
commit 3ed2749dc4
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
kombu/transport/pika2.py
View File

@ -103,8 +103,7 @@ class Channel(blocking.BlockingChannel, base.StdChannel):
properties = spec.BasicProperties(priority=priority, properties = spec.BasicProperties(priority=priority,
content_type=content_type, content_type=content_type,
content_encoding=content_encoding, content_encoding=content_encoding,
headers=headers, headers=headers)
**properties)
return body, properties return body, properties
def message_to_python(self, raw_message): def message_to_python(self, raw_message):