Function uses 'msg' not 'message'

Fixes bug 932986

Change-Id: Iafc70145b7bc9d71fef19db0f303a65468b934cb
This commit is contained in:
Johannes Erdfelt 2012-02-15 18:58:45 +00:00
parent bd4d632861
commit 59ca8b0b44

View File

@ -171,7 +171,7 @@ class RabbitStrategy(strategy.Strategy):
def _send_message(self, msg, routing_key): def _send_message(self, msg, routing_key):
"""Send a message. Caller needs to catch exceptions for retry.""" """Send a message. Caller needs to catch exceptions for retry."""
msg = self.exchange.Message(json.dumps(message)) msg = self.exchange.Message(json.dumps(msg))
self.exchange.publish(msg, routing_key=routing_key) self.exchange.publish(msg, routing_key=routing_key)
def _notify(self, msg, priority): def _notify(self, msg, priority):