diff --git a/glance/notifier/notify_kombu.py b/glance/notifier/notify_kombu.py index bcdabc543d..6a56fbae19 100644 --- a/glance/notifier/notify_kombu.py +++ b/glance/notifier/notify_kombu.py @@ -171,7 +171,7 @@ def log_failure(self, msg, priority): def _send_message(self, msg, routing_key): """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) def _notify(self, msg, priority):