diff options
author | Ask Solem <ask@celeryproject.org> | 2012-11-14 16:46:08 +0000 |
---|---|---|
committer | Ask Solem <ask@celeryproject.org> | 2012-11-15 12:54:34 +0000 |
commit | 325fcc0522571096b424080c232f0d87a1e5865e (patch) | |
tree | b483ac6cf52a1885890af0fe550e0dfb2f6afd24 /kombu/transport/pyamqp.py | |
parent | 4160f35da03a2c684e678674283f2a08202882f6 (diff) | |
download | kombu-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.py | 4 |
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, |