ce64b6abfc
Move it here so that it can be kept in sync with openstack-common using the new update.py script for code in openstack-common's incubation area. See here for more details: http://wiki.openstack.org/CommonLibrary#Incubation Note: this commit just moves the existing code in Nova with no other changes. A subsequent commit will sync it with latest openstack-common so that it is easier see the new changes. Change-Id: If88d678b1b9bad3d37117de7f7159d7fea8ab4c8
73 lines
2.2 KiB
Python
73 lines
2.2 KiB
Python
# Copyright 2011 OpenStack LLC.
|
|
# All Rights Reserved.
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
|
# not use this file except in compliance with the License. You may obtain
|
|
# a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
|
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
|
# License for the specific language governing permissions and limitations
|
|
# under the License.
|
|
|
|
from nova import flags
|
|
from nova import log as logging
|
|
from nova.openstack.common import cfg
|
|
from nova import utils
|
|
from nova.exception import ClassNotFound
|
|
|
|
|
|
list_notifier_drivers_opt = \
|
|
cfg.MultiStrOpt('list_notifier_drivers',
|
|
default=['nova.notifier.no_op_notifier'],
|
|
help='List of drivers to send notifications')
|
|
|
|
FLAGS = flags.FLAGS
|
|
FLAGS.add_option(list_notifier_drivers_opt)
|
|
|
|
LOG = logging.getLogger('nova.notifier.list_notifier')
|
|
|
|
drivers = None
|
|
|
|
|
|
class ImportFailureNotifier(object):
|
|
"""Noisily re-raises some exception over-and-over when notify is called."""
|
|
|
|
def __init__(self, exception):
|
|
self.exception = exception
|
|
|
|
def notify(self, message):
|
|
raise self.exception
|
|
|
|
|
|
def _get_drivers():
|
|
"""Instantiates and returns drivers based on the flag values."""
|
|
global drivers
|
|
if not drivers:
|
|
drivers = []
|
|
for notification_driver in FLAGS.list_notifier_drivers:
|
|
try:
|
|
drivers.append(utils.import_object(notification_driver))
|
|
except ClassNotFound as e:
|
|
drivers.append(ImportFailureNotifier(e))
|
|
return drivers
|
|
|
|
|
|
def notify(message):
|
|
"""Passes notification to multiple notifiers in a list."""
|
|
for driver in _get_drivers():
|
|
try:
|
|
driver.notify(message)
|
|
except Exception as e:
|
|
LOG.exception(_("Problem '%(e)s' attempting to send to "
|
|
"notification driver %(driver)s." % locals()))
|
|
|
|
|
|
def _reset_drivers():
|
|
"""Used by unit tests to reset the drivers."""
|
|
global drivers
|
|
drivers = None
|