summaryrefslogtreecommitdiff
path: root/kombu/transport/pyamqp.py
diff options
context:
space:
mode:
authorAsk Solem <ask@celeryproject.org>2012-11-14 16:46:08 +0000
committerAsk Solem <ask@celeryproject.org>2012-11-15 12:54:34 +0000
commit325fcc0522571096b424080c232f0d87a1e5865e (patch)
treeb483ac6cf52a1885890af0fe550e0dfb2f6afd24 /kombu/transport/pyamqp.py
parent4160f35da03a2c684e678674283f2a08202882f6 (diff)
downloadkombu-325fcc0522571096b424080c232f0d87a1e5865e.tar.gz
Producer: Support lazy channels using ChannelPromise, and connections will always be treated lazily (though, auto_declare will force evaluation, so a good idea to stop using it)
Diffstat (limited to 'kombu/transport/pyamqp.py')
-rw-r--r--kombu/transport/pyamqp.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/kombu/transport/pyamqp.py b/kombu/transport/pyamqp.py
index 1274be11..d03178e0 100644
--- a/kombu/transport/pyamqp.py
+++ b/kombu/transport/pyamqp.py
@@ -45,11 +45,11 @@ class Message(base.Message):
class Channel(amqp.Channel, base.StdChannel):
Message = Message
- def prepare_message(self, message_data, priority=None,
+ def prepare_message(self, body, priority=None,
content_type=None, content_encoding=None, headers=None,
properties=None):
"""Encapsulate data into a AMQP message."""
- return amqp.Message(message_data, priority=priority,
+ return amqp.Message(body, priority=priority,
content_type=content_type,
content_encoding=content_encoding,
application_headers=headers,