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

Merge branch 'robottaway/master'

This commit is contained in:
Ask Solem 2011-01-06 13:28:12 +01:00
parent d50b27f160 a60da56e18
commit 1d389f0355
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
kombu/transport/pypika.py
View File

@ -25,12 +25,13 @@ DEFAULT_PORT = 5672
class Message(base.Message): class Message(base.Message):
def __init__(self, channel, amqp_message, **kwargs): def __init__(self, channel, amqp_message, **kwargs):
channel_id, method, header, body = amqp_message channel_id, method, props, body = amqp_message
kwargs.update({"body": body, kwargs.update({"body": body,
"delivery_tag": method.delivery_tag, "delivery_tag": method.delivery_tag,
"content_type": header.content_type, "content_type": props.content_type,
"content_encoding": header.content_encoding, "content_encoding": props.content_encoding,
"headers": props.headers,
"delivery_info": dict( "delivery_info": dict(
consumer_tag=getattr(method, "consumer_tag", None), consumer_tag=getattr(method, "consumer_tag", None),
routing_key=method.routing_key, routing_key=method.routing_key,