Browse files

Renamed Exchange.create_message -> Exchange.Message

  • Loading branch information...
1 parent 4b0d426 commit ad45115c0ee65266bcd2d01650a02551eaf0d3ea Ask Solem committed Jul 23, 2010
Showing with 6 additions and 6 deletions.
  1. +6 −6 kombu/messaging.py
View
12 kombu/messaging.py
@@ -58,12 +58,12 @@ def publish(self, message_data, routing_key=None, delivery_mode=None,
message_data, content_type, content_encoding = self.prepare(
message_data, content_type, content_encoding)
- message = self.exchange.create_message(message_data,
- delivery_mode,
- priority,
- content_type,
- content_encoding,
- headers=headers)
+ message = self.exchange.Message(message_data,
+ delivery_mode,
+ priority,
+ content_type,
+ content_encoding,
+ headers=headers)
return self.exchange.publish(message, routing_key, mandatory,
immediate)

0 comments on commit ad45115

Please sign in to comment.