Merge from oslo-incubator for notifier

Goal: merge from oslo-incubator change  I282d4ae3311bc3fcda6be8e5a1fceecfc8ddb115

Done via:
python update.py --nodeps --base nova --dest-dir ../nova --modules notifier

Change-Id: I5ed80458f1073d6e5185e2769eed85a49dec5d10
This commit is contained in:
Andreas Jaeger
2013-08-12 09:35:34 +02:00
parent f1a5a4792a
commit e01764605e
4 changed files with 13 additions and 26 deletions

View File

@@ -19,7 +19,7 @@ import uuid
from oslo.config import cfg from oslo.config import cfg
from nova.openstack.common import context from nova.openstack.common import context
from nova.openstack.common.gettextutils import _ from nova.openstack.common.gettextutils import _ # noqa
from nova.openstack.common import importutils from nova.openstack.common import importutils
from nova.openstack.common import jsonutils from nova.openstack.common import jsonutils
from nova.openstack.common import log as logging from nova.openstack.common import log as logging
@@ -157,17 +157,6 @@ def _get_drivers():
if _drivers is None: if _drivers is None:
_drivers = {} _drivers = {}
for notification_driver in CONF.notification_driver: for notification_driver in CONF.notification_driver:
add_driver(notification_driver)
return _drivers.values()
def add_driver(notification_driver):
"""Add a notification driver at runtime."""
# Make sure the driver list is initialized.
_get_drivers()
if isinstance(notification_driver, basestring):
# Load and add
try: try:
driver = importutils.import_module(notification_driver) driver = importutils.import_module(notification_driver)
_drivers[notification_driver] = driver _drivers[notification_driver] = driver
@@ -175,9 +164,7 @@ def add_driver(notification_driver):
LOG.exception(_("Failed to load notifier %s. " LOG.exception(_("Failed to load notifier %s. "
"These notifications will not be sent.") % "These notifications will not be sent.") %
notification_driver) notification_driver)
else: return _drivers.values()
# Driver is already loaded; just add the object.
_drivers[notification_driver] = notification_driver
def _reset_drivers(): def _reset_drivers():

View File

@@ -25,7 +25,7 @@ CONF = cfg.CONF
def notify(_context, message): def notify(_context, message):
"""Notifies the recipient of the desired event given the model. """Notifies the recipient of the desired event given the model.
Log notifications using openstack's default logging system. Log notifications using OpenStack's default logging system.
""" """
priority = message.get('priority', priority = message.get('priority',

View File

@@ -16,7 +16,7 @@
from oslo.config import cfg from oslo.config import cfg
from nova.openstack.common import context as req_context from nova.openstack.common import context as req_context
from nova.openstack.common.gettextutils import _ from nova.openstack.common.gettextutils import _ # noqa
from nova.openstack.common import log as logging from nova.openstack.common import log as logging
from nova.openstack.common import rpc from nova.openstack.common import rpc
@@ -24,7 +24,7 @@ LOG = logging.getLogger(__name__)
notification_topic_opt = cfg.ListOpt( notification_topic_opt = cfg.ListOpt(
'notification_topics', default=['notifications', ], 'notification_topics', default=['notifications', ],
help='AMQP topic used for openstack notifications') help='AMQP topic used for OpenStack notifications')
CONF = cfg.CONF CONF = cfg.CONF
CONF.register_opt(notification_topic_opt) CONF.register_opt(notification_topic_opt)

View File

@@ -18,7 +18,7 @@
from oslo.config import cfg from oslo.config import cfg
from nova.openstack.common import context as req_context from nova.openstack.common import context as req_context
from nova.openstack.common.gettextutils import _ from nova.openstack.common.gettextutils import _ # noqa
from nova.openstack.common import log as logging from nova.openstack.common import log as logging
from nova.openstack.common import rpc from nova.openstack.common import rpc
@@ -26,7 +26,7 @@ LOG = logging.getLogger(__name__)
notification_topic_opt = cfg.ListOpt( notification_topic_opt = cfg.ListOpt(
'topics', default=['notifications', ], 'topics', default=['notifications', ],
help='AMQP topic(s) used for openstack notifications') help='AMQP topic(s) used for OpenStack notifications')
opt_group = cfg.OptGroup(name='rpc_notifier2', opt_group = cfg.OptGroup(name='rpc_notifier2',
title='Options for rpc_notifier2') title='Options for rpc_notifier2')