x/python-ganttclient
Code Issues Proposed changes

Merge prop changes

Browse Source
This commit is contained in:
Cerberus
2011-05-16 15:16:34 -05:00
parent e082578a1e
commit c082b0f1d1
6 changed files with 44 additions and 47 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
nova/notifier/rabbit_notifier.py
View File

@@ -25,14 +25,11 @@ flags.DEFINE_string('notification_topic', 'notifications',
'RabbitMQ topic used for Nova notifications')
class RabbitNotifier(object):
"""Sends notifications to a specific RabbitMQ server and topic"""
def notify(self, message):
"""Sends a notification to the RabbitMQ"""
context = nova.context.get_admin_context()
priority = message.get('priority',
FLAGS.default_notification_level)
priority = priority.lower()
topic = '%s.%s' % (FLAGS.notification_topic, priority)
rpc.cast(context, topic, message)
def notify(message):
"""Sends a notification to the RabbitMQ"""
context = nova.context.get_admin_context()
priority = message.get('priority',
FLAGS.default_notification_level)
priority = priority.lower()
topic = '%s.%s' % (FLAGS.notification_topic, priority)
rpc.cast(context, topic, message)