517de47726
Note that previously several notification drivers created an admin context and embedded it in their messages. Those drivers now use the passed-in context instead if it's available. For blueprint novaplugins. Change-Id: Icb89030256022d0a68db4a147611fd37fe83316a
71 lines
2.2 KiB
Python
71 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.openstack.common import importutils
|
|
|
|
|
|
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.register_opt(list_notifier_drivers_opt)
|
|
|
|
LOG = logging.getLogger(__name__)
|
|
|
|
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, context, 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(importutils.import_module(notification_driver))
|
|
except ImportError as e:
|
|
drivers.append(ImportFailureNotifier(e))
|
|
return drivers
|
|
|
|
|
|
def notify(context, message):
|
|
"""Passes notification to multiple notifiers in a list."""
|
|
for driver in _get_drivers():
|
|
try:
|
|
driver.notify(context, 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
|