Fixes problem with pidbox on 2.6 (kwargs must be str)

This commit is contained in:
Ask Solem 2012-11-29 12:44:14 +00:00
parent fd3aa52383
commit 724a5d4fe6
1 changed files with 1 additions and 1 deletions

View File

@ -103,7 +103,7 @@ class Node(object):
if message:
self.adjust_clock(message.headers.get('clock') or 0)
if not destination or self.hostname in destination:
return self.dispatch(**body)
return self.dispatch(**kwdict(body))
dispatch_from_message = handle_message
def reply(self, data, exchange, routing_key, ticket, **kwargs):