From 4c7cdc875ea19cb790275fc72b21fde2c61a5086 Mon Sep 17 00:00:00 2001 From: Ask Solem Date: Wed, 12 Jan 2011 15:48:53 +0100 Subject: [PATCH] message_data -> body --- kombu/pidbox.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/kombu/pidbox.py b/kombu/pidbox.py index 20162bce..d34bbcdf 100644 --- a/kombu/pidbox.py +++ b/kombu/pidbox.py @@ -97,8 +97,8 @@ class Node(object): def handle_cast(self, method, arguments): return self.handle(method, arguments) - def handle_message(self, message_data, message): - return self.dispatch_from_message(message_data) + def handle_message(self, body, message): + return self.dispatch_from_message(body) def reply(self, data, exchange, routing_key, **kwargs): self.mailbox._publish_reply(data, exchange, routing_key, @@ -240,10 +240,10 @@ class Mailbox(object): consumer = Consumer(channel, [queue], no_ack=True) responses = [] - def on_message(message_data, message): + def on_message(body, message): if callback: - callback(message_data) - responses.append(message_data) + callback(body) + responses.append(body) try: consumer.register_callback(on_message)