From a60da56e18cfda180f17d52a1235628e6f5b375b Mon Sep 17 00:00:00 2001 From: Rob Ottaway Date: Tue, 21 Dec 2010 11:01:25 -0800 Subject: [PATCH] Fixing missing headers issue --- kombu/transport/pypika.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/kombu/transport/pypika.py b/kombu/transport/pypika.py index ce7d549e..82ec3db4 100644 --- a/kombu/transport/pypika.py +++ b/kombu/transport/pypika.py @@ -25,12 +25,13 @@ DEFAULT_PORT = 5672 class Message(base.Message): 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, "delivery_tag": method.delivery_tag, - "content_type": header.content_type, - "content_encoding": header.content_encoding, + "content_type": props.content_type, + "content_encoding": props.content_encoding, + "headers": props.headers, "delivery_info": dict( consumer_tag=getattr(method, "consumer_tag", None), routing_key=method.routing_key,